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

Class LongWatermarkDeclaration

java.lang.Object

org.apache.flink.api.common.watermark.LongWatermarkDeclaration

All Implemented Interfaces:

Serializable, WatermarkDeclaration

@Experimental
public class LongWatermarkDeclaration
extends Object
implements WatermarkDeclaration

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

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected WatermarkCombinationPolicy	combinationPolicy
protected WatermarkHandlingStrategy	defaultHandlingStrategy
protected String	identifier
protected static long	serialVersionUID

Constructor Summary

Constructors

Constructor	Description
LongWatermarkDeclaration(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()
LongWatermark	newWatermark(long val)	Creates a new LongWatermark with the specified long value.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

serialVersionUID

protected static final long serialVersionUID

See Also:

Constant Field Values

identifier

protected final String identifier

combinationPolicy

protected final WatermarkCombinationPolicy combinationPolicy

defaultHandlingStrategy

protected final WatermarkHandlingStrategy defaultHandlingStrategy

Constructor Detail

LongWatermarkDeclaration

public LongWatermarkDeclaration(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 LongWatermark newWatermark(long val)

Creates a new LongWatermark with the specified long 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