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 Default Methods Modifier and Type Method Description default 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
default 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.The default implementation that returns
SystemClockis only for 1.19 and 1.20 release to keep binary compatibility of the user's code.- See Also:
RelativeClock
-
-