Demos

1. Demo: Internals of FlatMapGroupsWithStateExec Physical Operator

2. Demo: Exploring Checkpointed State

3. Demo: Streaming Watermark with Aggregation in Append Output Mode

4. Demo: Streaming Query for Running Counts (Socket Source and Complete Output Mode)

5. Demo: Streaming Aggregation with Kafka Data Source

6. Demo: groupByKey Streaming Aggregation in Update Mode

7. Demo: StateStoreSaveExec with Complete Output Mode

8. Demo: StateStoreSaveExec with Update Output Mode

9. Developing Custom Streaming Sink (and Monitoring SQL Queries in web UI)

10. current_timestamp Function For Processing Time in Streaming Queries

11. Using StreamingQueryManager for Query Termination Management