Module processing 

Advanced Event Processing Module

This module provides sophisticated event processing capabilities including:

• Time-based and count-based windowing
• Streaming aggregations (count, sum, average, min, max)
• Complex event pattern detection
• Event correlation and causality tracking
• Real-time analytics and metrics computation

The module is organized into several sub-modules:

• window: Window management and windowing logic
• aggregation: Aggregation functions and state management
• processor: Main event processing engine
• complex: Complex event processing patterns
• analytics: Real-time analytics and metrics
• anomaly: Anomaly detection capabilities
• temporal: Advanced temporal processing
• causality: Causality analysis and correlation

Re-exports

pub use aggregation::AggregateFunction;

pub use aggregation::AggregationManager;

pub use aggregation::AggregationState;

pub use joins::JoinCondition;

pub use joins::JoinConfig;

pub use joins::JoinStats;

pub use joins::JoinType;

pub use joins::JoinWindowStrategy;

pub use joins::JoinedEvent;

pub use joins::StreamJoiner;

pub use operators::DebounceOperator;

pub use operators::DistinctOperator;

pub use operators::FilterOperator;

pub use operators::FlatMapOperator;

pub use operators::MapOperator;

pub use operators::OperatorPipeline;

pub use operators::OperatorStats;

pub use operators::PartitionOperator;

pub use operators::PipelineBuilder;

pub use operators::PipelineStats;

pub use operators::ReduceOperator;

pub use operators::StreamOperator;

pub use operators::ThrottleOperator;

pub use pattern::Pattern;

pub use pattern::PatternMatch;

pub use pattern::PatternMatchStrategy;

pub use pattern::PatternMatcher;

pub use pattern::PatternMatcherStats;

pub use pattern::StatisticalPatternType;

pub use processor::EventProcessor;

pub use processor::ProcessorConfig;

pub use processor::ProcessorStats;

pub use simd_ops::SimdAggregateResult;

pub use simd_ops::SimdBatchConfig;

pub use simd_ops::SimdBatchProcessor;

pub use simd_ops::SimdEventFilter;

pub use simd_ops::SimdProcessorStats;

pub use window::EventWindow;

pub use window::Watermark;

pub use window::WindowConfig;

pub use window::WindowResult;

pub use window::WindowTrigger;

pub use window::WindowType;

Modules

aggregation

Aggregation functions and state management for event processing

joins

Stream Joins Module

operators

Advanced Stream Operators

pattern

Complex Event Pattern Matching

processor

Main event processor implementation

simd_ops

SIMD-Accelerated Stream Operations

window

Window management for event processing