org.apache.beam.sdk.transforms.splittabledofn

Class WatermarkEstimators

java.lang.Object

org.apache.beam.sdk.transforms.splittabledofn.WatermarkEstimators

public class WatermarkEstimators
extends java.lang.Object

A set of WatermarkEstimators that users can use to advance the output watermark for their associated splittable DoFns.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WatermarkEstimators.Manual Concrete implementation of a ManualWatermarkEstimator.
static class	WatermarkEstimators.MonotonicallyIncreasing A watermark estimator that observes timestamps of records output from a DoFn reporting the timestamp of the last element seen as the current watermark.
static class	WatermarkEstimators.WallTime A watermark estimator that tracks wall time.

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait