public static class WatermarkPolicyFactory.ArrivalTimeWatermarkPolicy extends java.lang.Object implements WatermarkPolicy
WatermarkPolicyFactory.CustomWatermarkPolicy
for watermark computation. It
uses the arrival time of the record as the event time for watermark calculations.Modifier and Type | Method and Description |
---|---|
Instant |
getWatermark() |
void |
update(KinesisRecord record) |
public Instant getWatermark()
getWatermark
in interface WatermarkPolicy
public void update(KinesisRecord record)
update
in interface WatermarkPolicy