Interface WatermarkGeneratorSupplier.Context

    • Method Detail

      • getMetricGroup

        org.apache.flink.metrics.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

        default 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.

        The default implementation that returns SystemClock is only for 1.19 and 1.20 release to keep binary compatibility of the user's code.

        See Also:
        RelativeClock