org.apache.flink.api.common.eventtime

Class WatermarkAlignmentParams

java.lang.Object

org.apache.flink.api.common.eventtime.WatermarkAlignmentParams

All Implemented Interfaces:

Serializable

@PublicEvolving
public final class WatermarkAlignmentParams
extends Object
implements Serializable

Configuration parameters for watermark alignment.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static WatermarkAlignmentParams	WATERMARK_ALIGNMENT_DISABLED

Constructor Summary

Constructors

Constructor and Description
WatermarkAlignmentParams(long maxAllowedWatermarkDrift, String watermarkGroup, long updateInterval)

Method Summary

Modifier and Type	Method and Description
long	getMaxAllowedWatermarkDrift()
long	getUpdateInterval()
String	getWatermarkGroup()
boolean	isEnabled()

Methods inherited from class java.lang.Object

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

Field Detail

WATERMARK_ALIGNMENT_DISABLED

public static final WatermarkAlignmentParams WATERMARK_ALIGNMENT_DISABLED

Constructor Detail

WatermarkAlignmentParams

public WatermarkAlignmentParams(long maxAllowedWatermarkDrift,
                                String watermarkGroup,
                                long updateInterval)

Method Detail

isEnabled

public boolean isEnabled()

getMaxAllowedWatermarkDrift

public long getMaxAllowedWatermarkDrift()

getWatermarkGroup

public String getWatermarkGroup()

getUpdateInterval

public long getUpdateInterval()