@Internal public final class TimestampsAndWatermarksContext extends Object implements TimestampAssignerSupplier.Context, WatermarkGeneratorSupplier.Context
TimestampAssignerSupplier.Context
and
WatermarkGeneratorSupplier.Context
.Constructor and Description |
---|
TimestampsAndWatermarksContext(MetricGroup metricGroup) |
Modifier and Type | Method and Description |
---|---|
MetricGroup |
getMetricGroup()
Returns the metric group for the context in which the created
TimestampAssigner
is used. |
public TimestampsAndWatermarksContext(MetricGroup metricGroup)
public MetricGroup getMetricGroup()
TimestampAssignerSupplier.Context
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.
getMetricGroup
in interface TimestampAssignerSupplier.Context
getMetricGroup
in interface WatermarkGeneratorSupplier.Context
MetricGroup
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.