Uses of Class
com.hazelcast.jet.pipeline.WindowDefinition
Package
Description
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of WindowDefinition in com.hazelcast.jet.pipeline
Modifier and TypeClassDescriptionclass
Represents the definition of a session window.class
Represents the definition of a sliding window.Modifier and TypeMethodDescriptionWindowDefinition.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.StageWithKeyAndWindow.windowDefinition()
Returns the definition of the window for the windowed aggregation operation that you are about to construct using this object.StageWithWindow.windowDefinition()
Returns the definition of the window for the windowed aggregation operation that you are about to construct using this object.Modifier and TypeMethodDescriptionStreamStage.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.StreamStageWithKey.window
(WindowDefinition wDef) Adds the definition of the window to use in the group-and-aggregate pipeline stage being constructed.