org.apache.beam.sdk.io.kinesis

Class WatermarkPolicyFactory.ProcessingTimeWatermarkPolicy

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, WatermarkPolicy

Enclosing interface:

WatermarkPolicyFactory

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

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ProcessingTimeWatermarkPolicy()

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

Constructor Detail

ProcessingTimeWatermarkPolicy

public ProcessingTimeWatermarkPolicy()

Method Detail

getWatermark

public Instant getWatermark()

Specified by:

getWatermark in interface WatermarkPolicy

update

public void update(KinesisRecord record)

Specified by:

update in interface WatermarkPolicy