Skip to content


KGroupedStreamImpl is a KGroupedStream (and an AbstractStream).

Creating Instance

KGroupedStreamImpl takes the following to be created:

KGroupedStreamImpl is created when:


KGroupedStreamImpl creates a GroupedStreamAggregateBuilder when created.

repartitionRequired Flag

KGroupedStreamImpl is given a repartitionRequired flag when created.

The repartitionRequired flag is always true for groupBy.

Back to top