Package org.apache.beam.sdk.transforms.splittabledofn

Class WatermarkEstimators

java.lang.Object

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

public class WatermarkEstimators
extends 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	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