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

Interface WatermarkPolicy

All Superinterfaces:

Serializable

All Known Implementing Classes:

WatermarkPolicyFactory.ArrivalTimeWatermarkPolicy, WatermarkPolicyFactory.CustomWatermarkPolicy, WatermarkPolicyFactory.ProcessingTimeWatermarkPolicy

public interface WatermarkPolicy
extends Serializable

Implement this interface to define a custom watermark calculation heuristic.

Method Summary

Modifier and Type	Method	Description
Instant	getWatermark()
void	update(KinesisRecord record)

Method Details

getWatermark

Instant getWatermark()

update

void update(KinesisRecord record)