public class HeartbeatRecordAction extends java.lang.Object
ReadChangeStreamPartitionDoFnSDF. It is responsible for processing
HeartbeatRecords. The records will be used to progress the watermark for the current element (partition).
|Modifier and Type||Method and Description|
This is the main processing function for a
public java.util.Optional<DoFn.ProcessContinuation> run(PartitionMetadata partition, HeartbeatRecord record, RestrictionTracker<TimestampRange,com.google.cloud.Timestamp> tracker, ManualWatermarkEstimator<Instant> watermarkEstimator)
HeartbeatRecord. It returns an
DoFn.ProcessContinuationto indicate if the calling function should stop or not. If the
Optionalreturned is empty, it means that the calling function can continue with the processing. If an
DoFn.ProcessContinuation.stop()is returned, it means that this function was unable to claim the timestamp of the
HeartbeatRecord, so the caller should stop.
When processing the
HeartbeatRecord the following procedure is applied: