Labs
Filtering a Stream (Ride Cleansing)
Stateful Enrichment (Rides and Fares)
Windowed Analytics (Hourly Tips)
Exercise
Discussion
ProcessFunction
and Timers (Long Ride Alerts)
Exercise
Discussion