com.hazelcast.jet.pipeline

Class SlidingWindowDef

java.lang.Object

com.hazelcast.jet.pipeline.SlidingWindowDef

All Implemented Interfaces:

WindowDefinition

public class SlidingWindowDef
extends Object
implements WindowDefinition

Represents the definition of a sliding window.

Nested Class Summary

Nested classes/interfaces inherited from interface com.hazelcast.jet.pipeline.WindowDefinition

WindowDefinition.WindowKind

Method Summary

Modifier and Type	Method and Description
SlidingWindowDef	downcast() Returns this window definition downcast to the type determined through type inference at the call site.
WindowDefinition.WindowKind	kind() Returns what kind of window this definition describes.
long	slideBy() Returns the size of the sliding step.
SlidingWindowPolicy	toSlidingWindowPolicy() Returns the policy object used by the Core API processors to drive the sliding window logic.
long	watermarkFrameSize() Returns the frameLength and offset this window definition needs.
long	windowSize() Returns the length of the window (the size of the timestamp range it covers).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.hazelcast.jet.pipeline.WindowDefinition

session, sliding, tumbling

Method Detail

kind

@Nonnull
public WindowDefinition.WindowKind kind()

Description copied from interface: WindowDefinition

Returns what kind of window this definition describes.

Specified by:

kind in interface WindowDefinition

downcast

@Nonnull
public SlidingWindowDef downcast()

Description copied from interface: WindowDefinition

Returns this window definition downcast to the type determined through type inference at the call site. It will be an unchecked downcast and may fail at runtime with a ClassCastException.

Specified by:

downcast in interface WindowDefinition

Returns:

this object, downcast into the inferred type

watermarkFrameSize

public long watermarkFrameSize()

Description copied from interface: WindowDefinition

Returns the frameLength and offset this window definition needs.

Specified by:

watermarkFrameSize in interface WindowDefinition

windowSize

public long windowSize()

Returns the length of the window (the size of the timestamp range it covers). It is an integer multiple of slideBy().

slideBy

public long slideBy()

Returns the size of the sliding step.

toSlidingWindowPolicy

public SlidingWindowPolicy toSlidingWindowPolicy()

Returns the policy object used by the Core API processors to drive the sliding window logic.