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

Class WatermarkPolicyFactory.ProcessingTimeWatermarkPolicy

java.lang.Object

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

All Implemented Interfaces:

Serializable, WatermarkPolicy

Enclosing interface:

WatermarkPolicyFactory

public static class WatermarkPolicyFactory.ProcessingTimeWatermarkPolicy
extends Object
implements WatermarkPolicy

Watermark policy where the processing time is used as the event time.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
ProcessingTimeWatermarkPolicy()

Method Summary

Modifier and Type	Method	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

Constructor Details

ProcessingTimeWatermarkPolicy

public ProcessingTimeWatermarkPolicy()

Method Details

getWatermark

public Instant getWatermark()

Specified by:

getWatermark in interface WatermarkPolicy

update

public void update(KinesisRecord record)

Specified by:

update in interface WatermarkPolicy