Demo¶

• Arbitrary Stateful Streaming Aggregation with KeyValueGroupedDataset.flatMapGroupsWithState Operator
• current_timestamp Function For Processing Time in Streaming Queries
• Custom Streaming Sink (and Monitoring SQL Queries in web UI)
• Deep Dive into FileStreamSink
• Exploring Checkpointed State
• groupByKey Streaming Aggregation in Update Mode
• Internals of FlatMapGroupsWithStateExec Physical Operator
• Kafka Data Source
• Streaming Windowed Aggregation
• RocksDB State Store for Streaming Aggregation
• Stream-Stream Inner Join
• Streaming Query for Running Counts (Socket Source and Complete Output Mode)
• Streaming Watermark
• Streaming Watermark with Aggregation in Append Output Mode
• StateStoreSaveExec with Complete Output Mode
• StateStoreSaveExec with Update Output Mode
• Using StreamingQueryManager for Query Termination Management
• Using File Streaming Source