org.apache.beam.sdk.io.kinesis

Class WatermarkPolicyFactory.ArrivalTimeWatermarkPolicy

java.lang.Object

org.apache.beam.sdk.io.kinesis.WatermarkPolicyFactory.ArrivalTimeWatermarkPolicy

All Implemented Interfaces:

java.io.Serializable, WatermarkPolicy

Enclosing interface:

WatermarkPolicyFactory

public static class WatermarkPolicyFactory.ArrivalTimeWatermarkPolicy
extends java.lang.Object
implements WatermarkPolicy

ArrivalTimeWatermarkPolicy uses WatermarkPolicyFactory.CustomWatermarkPolicy for watermark computation. It uses the arrival time of the record as the event time for watermark calculations.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
Instant	getWatermark()
void	update(KinesisRecord record)

Methods inherited from class java.lang.Object

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

Method Detail

getWatermark

public Instant getWatermark()

Specified by:

getWatermark in interface WatermarkPolicy

update

public void update(KinesisRecord record)

Specified by:

update in interface WatermarkPolicy