org.apache.flink.streaming.api.operators.source

Class TimestampsAndWatermarksContext

java.lang.Object

org.apache.flink.streaming.api.operators.source.TimestampsAndWatermarksContext

All Implemented Interfaces:

TimestampAssignerSupplier.Context, WatermarkGeneratorSupplier.Context

@Internal
public final class TimestampsAndWatermarksContext
extends Object
implements TimestampAssignerSupplier.Context, WatermarkGeneratorSupplier.Context

A simple implementation of a context that is both TimestampAssignerSupplier.Context and WatermarkGeneratorSupplier.Context.

Constructor Summary

Constructors

Constructor and Description
TimestampsAndWatermarksContext(MetricGroup metricGroup, RelativeClock inputActivityClock)

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 TimestampAssigner is used.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TimestampsAndWatermarksContext

public TimestampsAndWatermarksContext(MetricGroup metricGroup,
                                      RelativeClock inputActivityClock)

Method Detail

getMetricGroup

public MetricGroup getMetricGroup()

Description copied from interface: TimestampAssignerSupplier.Context

Returns the metric group for the context in which the created TimestampAssigner 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.

Specified by:

getMetricGroup in interface TimestampAssignerSupplier.Context

Specified by:

getMetricGroup in interface WatermarkGeneratorSupplier.Context

See Also:

MetricGroup

getInputActivityClock

public RelativeClock getInputActivityClock()

Description copied from interface: WatermarkGeneratorSupplier.Context

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.

Specified by:

getInputActivityClock in interface WatermarkGeneratorSupplier.Context

See Also:

RelativeClock