WatermarkPolicyFactory.CustomWatermarkPolicy (Apache Beam 2.68.0)

java.lang.Object

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

All Implemented Interfaces:: Serializable, WatermarkPolicy

Enclosing interface:: WatermarkPolicyFactory

public static class WatermarkPolicyFactory.CustomWatermarkPolicy extends 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:

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

Method Details
- getWatermark
  
  public Instant getWatermark()
  
  Specified by:
  
  getWatermark in interface WatermarkPolicy
- update
  
  public void update(KinesisRecord record)
  
  Specified by:
  
  update in interface WatermarkPolicy