Struct TemporalGraphProcessor

pub struct TemporalGraphProcessor;

Temporal graph query processor for time-based edge filtering Supports queries like: SELECT * FROM edges WHERE edge_timestamp BETWEEN ‘2024-01-01’ AND ‘2024-12-31’

Implementations

impl TemporalGraphProcessor

pub fn new() -> Self

pub fn filter_edges_by_time( &self, edges: &[TemporalEdge], time_window: &TimeWindow, ) -> DataFusionResult<Vec<TemporalEdge>>

Filter edges by time window Example: Find all edges that occurred between two timestamps

pub fn get_graph_snapshot( &self, edges: &[TemporalEdge], snapshot_time: i64, ) -> DataFusionResult<Vec<TemporalEdge>>

Get graph snapshot at a specific timestamp Returns all edges that were active at the given time

pub fn find_temporal_paths( &self, edges: &[TemporalEdge], start_node: &str, end_node: &str, time_window: &TimeWindow, ) -> DataFusionResult<Vec<Vec<TemporalEdge>>>

Find temporal paths - paths that respect time ordering Each edge in the path must have a timestamp >= previous edge

pub fn aggregate_by_time_bucket( &self, edges: &[TemporalEdge], bucket_size_seconds: i64, ) -> DataFusionResult<HashMap<i64, usize>>

Aggregate edges by time buckets Example: Count edges per hour, day, week, etc.

pub fn get_active_nodes_at_time( &self, edges: &[TemporalEdge], timestamp: i64, lookback_window: i64, ) -> DataFusionResult<Vec<String>>

Find active nodes at a specific time Returns nodes that had at least one edge within the time window before the timestamp

pub fn calculate_temporal_centrality( &self, edges: &[TemporalEdge], node_id: &str, time_window: &TimeWindow, ) -> DataFusionResult<f64>

Calculate temporal centrality - how central a node is within a time window

pub fn parse_and_execute_temporal_query( &self, _query: &str, edges: &[TemporalEdge], config: &TemporalQueryConfig, ) -> DataFusionResult<Vec<TemporalEdge>>

Process a temporal SQL query (simplified parser) Example: “SELECT source, target FROM edges WHERE edge_timestamp BETWEEN 1704067200 AND 1735689600”

Trait Implementations

impl Default for TemporalGraphProcessor

fn default() -> Self

Returns the “default value” for a type.