org.apache.flink.api.common.eventtime

Interface WatermarkGeneratorSupplier.Context

All Known Implementing Classes:

TimestampsAndWatermarksContext

Enclosing interface:

WatermarkGeneratorSupplier<T>

public static interface WatermarkGeneratorSupplier.Context

Additional information available to WatermarkGeneratorSupplier.createWatermarkGenerator(Context). This can be access to MetricGroups, for example.

Method Summary

Modifier and Type	Method and Description
RelativeClock	getInputActivityClock() Returns a RelativeClock that hides periods when input was not active and WatermarkGenerator could not have been executed due to execution being blocked by the runtime.
MetricGroup	getMetricGroup() Returns the metric group for the context in which the created WatermarkGenerator is used.

Method Detail

getMetricGroup

MetricGroup getMetricGroup()

Returns the metric group for the context in which the created WatermarkGenerator is used.

Instances of this class can be used to register new metrics with Flink and to create a nested hierarchy based on the group names. See MetricGroup for more information for the metrics system.

See Also:

MetricGroup

getInputActivityClock

RelativeClock getInputActivityClock()

Returns a RelativeClock that hides periods when input was not active and WatermarkGenerator could not have been executed due to execution being blocked by the runtime. For example a backpressure or watermark alignment blocking the progress.

See Also:

RelativeClock