Package org.apache.flink.api.common.watermark

Class BoolWatermarkDeclaration

java.lang.Object

org.apache.flink.api.common.watermark.BoolWatermarkDeclaration

All Implemented Interfaces:

Serializable, WatermarkDeclaration

@Experimental
public class BoolWatermarkDeclaration
extends Object
implements WatermarkDeclaration

The BoolWatermarkDeclaration class implements the WatermarkDeclaration interface and provides additional functionality specific to boolean-type watermarks. It includes methods for obtaining combination semantics and creating new bool watermarks.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
BoolWatermarkDeclaration(String identifier, WatermarkCombinationPolicy combinationPolicy, WatermarkHandlingStrategy defaultHandlingStrategy)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
WatermarkCombinationPolicy	getCombinationPolicy()
WatermarkHandlingStrategy	getDefaultHandlingStrategy()
String	getIdentifier()	Returns the unique identifier for this watermark.
int	hashCode()
BoolWatermark	newWatermark(boolean val)	Creates a new BoolWatermark with the specified boolean value.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

BoolWatermarkDeclaration

public BoolWatermarkDeclaration(String identifier,
                                WatermarkCombinationPolicy combinationPolicy,
                                WatermarkHandlingStrategy defaultHandlingStrategy)

Method Detail

getIdentifier

public String getIdentifier()

Description copied from interface: WatermarkDeclaration

Returns the unique identifier for this watermark.

Specified by:

getIdentifier in interface WatermarkDeclaration

Returns:

a String representing the unique identifier of the watermark

newWatermark

public BoolWatermark newWatermark(boolean val)

Creates a new BoolWatermark with the specified boolean value.

getCombinationPolicy

public WatermarkCombinationPolicy getCombinationPolicy()

getDefaultHandlingStrategy

public WatermarkHandlingStrategy getDefaultHandlingStrategy()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object