public interface WatermarkPolicy extends java.io.Serializable
Instant
getWatermark()
void
update(KinesisRecord record)
Instant getWatermark()
void update(KinesisRecord record)