Uses of Class
com.hazelcast.jet.pipeline.WindowDefinition
Package | Description |
---|---|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
-
Uses of WindowDefinition in com.hazelcast.jet.pipeline
Subclasses of WindowDefinition in com.hazelcast.jet.pipeline Modifier and Type Class Description class
SessionWindowDefinition
Represents the definition of a session window.class
SlidingWindowDefinition
Represents the definition of a sliding window.Methods in com.hazelcast.jet.pipeline that return WindowDefinition Modifier and Type Method Description WindowDefinition
WindowDefinition. setEarlyResultsPeriod(long earlyResultPeriodMs)
Sets the period in milliseconds at which the windowed aggregation stage will emit partial results of all the windows that contain some data, but the watermark hasn't yet advanced enough to close them and emit the final results.WindowDefinition
StageWithKeyAndWindow. windowDefinition()
Returns the definition of the window for the windowed aggregation operation that you are about to construct using this object.WindowDefinition
StageWithWindow. windowDefinition()
Returns the definition of the window for the windowed aggregation operation that you are about to construct using this object.Methods in com.hazelcast.jet.pipeline with parameters of type WindowDefinition Modifier and Type Method Description StageWithWindow<T>
StreamStage. window(WindowDefinition wDef)
Adds the given window definition to this stage, as the first step in the construction of a pipeline stage that performs windowed aggregation.StageWithKeyAndWindow<T,K>
StreamStageWithKey. window(WindowDefinition wDef)
Adds the definition of the window to use in the group-and-aggregate pipeline stage being constructed.