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

Class JobManagerWatermarkTracker.WatermarkResult

java.lang.Object

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

All Implemented Interfaces:

Serializable

Enclosing class:

JobManagerWatermarkTracker

protected static class JobManagerWatermarkTracker.WatermarkResult
extends Object
implements Serializable

Watermark aggregation result.

See Also:

Serialized Form

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	WatermarkResult()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

watermark

protected long watermark

updateTimeoutCount

protected long updateTimeoutCount

Constructor Detail

WatermarkResult

protected WatermarkResult()