Package org.apache.flink.streaming.util

Class LatencyStats

java.lang.Object

org.apache.flink.streaming.util.LatencyStats

public class LatencyStats
extends Object

The LatencyStats objects are used to track and report on the behavior of latencies across measurements.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	LatencyStats.Granularity	Granularity for latency metrics.

Constructor Summary

Constructors

Constructor	Description
LatencyStats(MetricGroup metricGroup, int historySize, int subtaskIndex, OperatorID operatorID, LatencyStats.Granularity granularity)

Method Summary

Modifier and Type	Method	Description
void	reportLatency(LatencyMarker marker)

Methods inherited from class java.lang.Object

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

Constructor Detail

LatencyStats

public LatencyStats(MetricGroup metricGroup,
                    int historySize,
                    int subtaskIndex,
                    OperatorID operatorID,
                    LatencyStats.Granularity granularity)

Method Detail

reportLatency

public void reportLatency(LatencyMarker marker)