Uses of Class
com.hazelcast.jet.pipeline.WindowDefinition

Packages that use 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 and 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 and 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	StageWithWindow.windowDefinition() Returns the definition of the window for the windowed aggregation operation that you are about to construct using this object.
WindowDefinition	StageWithKeyAndWindow.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 and 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.