Expand description
Configuration types for the stream processor
This module provides configuration structures for all processor components including windows, watermarks, state backends, and aggregations.
Structs§
- Aggregation
Config - Aggregation configuration
- Deduplication
Config - Event deduplication configuration
- Normalization
Config - Time-series normalization configuration
- Processor
Config - Main processor configuration
- State
Config - State backend configuration
- Watermark
Config - Watermark configuration
- Window
Config - Window configuration
Enums§
- Aggregation
Type - Types of aggregations to compute
- Alignment
Strategy - Strategy for aligning event timestamps to intervals
- Deduplication
Strategy - Strategy for event deduplication
- Fill
Strategy - Strategy for filling missing data points in time-series normalization
- State
Backend - State backend type
- Watermark
Strategy - Watermark generation strategy
- Window
Type - Type of windowing strategy