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

Class WatermarkCombinationPolicy

java.lang.Object

org.apache.flink.api.common.watermark.WatermarkCombinationPolicy

All Implemented Interfaces:

Serializable

@Experimental
public class WatermarkCombinationPolicy
extends Object
implements Serializable

The WatermarkCombinationPolicy defines when and how to the combine Watermarks.

The watermark combination process will first check the setting of combineWaitForAllChannels. If it is set to true, the ProcessFunction must receive watermarks from all input channels before it can proceed with the combination.

The actual combination of watermarks will then be executed using the specified watermarkCombinationFunction.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
WatermarkCombinationPolicy(WatermarkCombinationFunction watermarkCombinationFunction, boolean combineWaitForAllChannels)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
WatermarkCombinationFunction	getWatermarkCombinationFunction()
int	hashCode()
boolean	isCombineWaitForAllChannels()

Methods inherited from class java.lang.Object

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

Constructor Detail

WatermarkCombinationPolicy

public WatermarkCombinationPolicy(WatermarkCombinationFunction watermarkCombinationFunction,
                                  boolean combineWaitForAllChannels)

Method Detail

getWatermarkCombinationFunction

public WatermarkCombinationFunction getWatermarkCombinationFunction()

isCombineWaitForAllChannels

public boolean isCombineWaitForAllChannels()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object