Create windowed aggregates
Process data across partitions
Process within one partition
Configure checkpoints and watermarking during processing
Create tests for data pipelines
Optimize pipelines for analytical or transactional purposes
Configure exception handling
Replay archived stream data
Handle failed batch loads