
GroupStateImpl
GroupStateImpl GroupStateImpl…FIXME

GroupStateImpl GroupStateImpl…FIXME

GroupState — State Per Group in Stateful Streaming Aggregation

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