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

Class JobManagerWatermarkTracker.WatermarkUpdate

java.lang.Object

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

All Implemented Interfaces:

Serializable

Enclosing class:

JobManagerWatermarkTracker

protected static class JobManagerWatermarkTracker.WatermarkUpdate
extends Object
implements Serializable

Watermark aggregation input.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected String	id
protected long	watermark

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	WatermarkUpdate()

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

id

protected String id

Constructor Detail

WatermarkUpdate

protected WatermarkUpdate()