Uses of Interface
com.hazelcast.jet.pipeline.GeneralStageWithKey
Package | Description |
---|---|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
-
Uses of GeneralStageWithKey in com.hazelcast.jet.pipeline
Subinterfaces of GeneralStageWithKey in com.hazelcast.jet.pipeline Modifier and Type Interface Description interface
BatchStageWithKey<T,K>
An intermediate step while constructing a group-and-aggregate batch pipeline stage.interface
StreamStageWithKey<T,K>
An intermediate step while constructing a pipeline transform that involves a grouping key, such as windowed group-and-aggregate.Methods in com.hazelcast.jet.pipeline that return GeneralStageWithKey Modifier and Type Method Description <K> GeneralStageWithKey<T,K>
GeneralStage. groupingKey(FunctionEx<? super T,? extends K> keyFn)
Specifies the function that will extract a key from the items in the associated pipeline stage.