org.apache.flink.statefun.flink.core.metrics

Class FlinkFunctionDispatcherMetrics

java.lang.Object

org.apache.flink.statefun.flink.core.metrics.FlinkFunctionDispatcherMetrics

All Implemented Interfaces:

FunctionDispatcherMetrics

public class FlinkFunctionDispatcherMetrics
extends java.lang.Object
implements FunctionDispatcherMetrics

Constructor Summary

Constructors

Constructor and Description
FlinkFunctionDispatcherMetrics(org.apache.flink.metrics.MetricGroup operatorGroup)

Method Summary

Modifier and Type	Method and Description
void	asyncOperationCompleted()
void	asyncOperationRegistered()

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkFunctionDispatcherMetrics

public FlinkFunctionDispatcherMetrics(org.apache.flink.metrics.MetricGroup operatorGroup)

Method Detail

asyncOperationRegistered

public void asyncOperationRegistered()

Specified by:

asyncOperationRegistered in interface FunctionDispatcherMetrics

asyncOperationCompleted

public void asyncOperationCompleted()

Specified by:

asyncOperationCompleted in interface FunctionDispatcherMetrics