Uses of Interface
com.hazelcast.jet.pipeline.StageWithKeyAndWindow

Packages that use StageWithKeyAndWindow

Package	Description
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

Uses of StageWithKeyAndWindow in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline that return StageWithKeyAndWindow

Modifier and Type	Method and Description
<K> StageWithKeyAndWindow<T,K>	StageWithWindow.groupingKey(FunctionEx<? super T,? extends K> keyFn) Specifies the function that will extract the grouping key from the items in the associated pipeline stage and moves on to the step in which you'll complete the construction of a windowed group-and-aggregate stage.
StageWithKeyAndWindow<T,K>	StreamStageWithKey.window(WindowDefinition wDef) Adds the definition of the window to use in the group-and-aggregate pipeline stage being constructed.