org.apache.flink.streaming.connectors.kinesis.util

Class WatermarkTracker.WatermarkState

java.lang.Object

org.apache.flink.streaming.connectors.kinesis.util.WatermarkTracker.WatermarkState

Enclosing class:

WatermarkTracker

protected static class WatermarkTracker.WatermarkState
extends Object

Watermark state.

Field Summary

Fields

Modifier and Type	Field and Description
protected long	lastUpdated
protected long	watermark

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	WatermarkState()

Method Summary

Modifier and Type	Method and Description
long	getWatermark()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

watermark

protected long watermark

lastUpdated

protected long lastUpdated

Constructor Detail

WatermarkState

protected WatermarkState()

Method Detail

getWatermark

public long getWatermark()

toString

public String toString()

Overrides:

toString in class Object