
flatMapGroupsWithState Operator — Arbitrary Stateful Streaming Aggregation (with Explicit State Logic)
flatMapGroupsWithState Operator — Arbitrary Stateful Streaming Aggregation (with Explicit State Logic)

flatMapGroupsWithState Operator — Arbitrary Stateful Streaming Aggregation (with Explicit State Logic)

mapGroupsWithState Operator — Stateful Streaming Aggregation (with Explicit State Logic)

KeyValueGroupedDataset — Streaming Aggregation

window Function — Stream Time Windows

withWatermark Operator — Event Time Watermark

groupByKey Operator — Streaming Aggregation (with Explicit State Logic)

groupBy Operator — Untyped Streaming Aggregation (with Implicit State Logic)

explain Operator — Explaining Query Plan

dropDuplicates Operator — Streaming Deduplication

Streaming Operators / Streaming Dataset API