org.apache.beam.sdk.io.aws2.kinesis

Class WatermarkPolicyFactory.CustomWatermarkPolicy

java.lang.Object

org.apache.beam.sdk.io.aws2.kinesis.WatermarkPolicyFactory.CustomWatermarkPolicy

All Implemented Interfaces:

java.io.Serializable, WatermarkPolicy

Enclosing interface:

WatermarkPolicyFactory

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

CustomWatermarkPolicy uses parameters defined in WatermarkParameters to compute watermarks. This can be used as a standard heuristic to compute watermarks. Used by WatermarkPolicyFactory.ArrivalTimeWatermarkPolicy.

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