Uses of Interface
com.hazelcast.jet.pipeline.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 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.