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