Structured Streaming Documentation
Aggregation
Initializing search
Home
Guides
Examples
Structured Streaming Documentation
Home
Guides
Guides
Overview
Input and output
Input and output
Sources
Sinks
Binary formats
Operators
Operators
Overview
Stateless operators
Stateless operators
Projection and selection
Additional operators
Stateful operators
Stateful operators
Watermarks
Aggregation
Deduplication
Joins
Groups with state
Stream options
Stream options
Triggers
Output mode
Checkpoints
State stores
Testing
Testing
Unit testing
Operations
Operations
Managing the query lifecycle
Monitoring the query lifecycle
Reading query progress
Examples
Examples
Aggregation with watermark
Deduplication
Aggregation
This is a work-in-progress. Please see the pending PRs.