Interface WatermarkGeneratorSupplier.Context
-
- Enclosing interface:
- WatermarkGeneratorSupplier<T>
public static interface WatermarkGeneratorSupplier.ContextAdditional information available toWatermarkGeneratorSupplier.createWatermarkGenerator(Context). This can be access toMetricGroups, for example.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description RelativeClockgetInputActivityClock()Returns aRelativeClockthat hides periods when input was not active andWatermarkGeneratorcould not have been executed due to execution being blocked by the runtime.org.apache.flink.metrics.MetricGroupgetMetricGroup()Returns the metric group for the context in which the createdWatermarkGeneratoris used.
-
-
-
Method Detail
-
getMetricGroup
org.apache.flink.metrics.MetricGroup getMetricGroup()
Returns the metric group for the context in which the createdWatermarkGeneratoris 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
MetricGroupfor more information for the metrics system.- See Also:
MetricGroup
-
getInputActivityClock
RelativeClock getInputActivityClock()
Returns aRelativeClockthat hides periods when input was not active andWatermarkGeneratorcould 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
-
-