Expand description
Streaming execution support for large graphs and datasets.
Structs§
- Backpressure
Config - Backpressure configuration for stream processing.
- Chunk
Iterator - Chunk iterator for breaking large batches into streams
- Chunk
Metadata - Stream chunk metadata
- Stream
Processor - Stream processor for handling streaming execution
- Stream
Result - Streaming execution result with chunk information
- Streaming
Config - Configuration for streaming execution
- Streaming
Config V2 - Extended streaming configuration combining the base config with v2 features.
- Streaming
Stats - Runtime statistics for a stream processing session.
- Watermark
Config - Watermark configuration for handling out-of-order events.
Enums§
- Backpressure
Strategy - Strategy applied when the buffer is full.
- Streaming
Mode - Streaming execution mode for handling large datasets
Traits§
- TlStreaming
Executor - Trait for executors that support streaming execution