org.apache.flink.runtime.metrics

Class ViewUpdater

java.lang.Object

org.apache.flink.runtime.metrics.ViewUpdater

public class ViewUpdater
extends Object

The ViewUpdater is responsible for updating all metrics that implement the View interface.

Constructor Summary

Constructors

Constructor and Description
ViewUpdater(ScheduledExecutorService executor)

Method Summary

Modifier and Type	Method and Description
void	notifyOfAddedView(View view) Notifies this ViewUpdater of a new metric that should be regularly updated.
void	notifyOfRemovedView(View view) Notifies this ViewUpdater of a metric that should no longer be regularly updated.

Methods inherited from class java.lang.Object

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

Constructor Detail

ViewUpdater

public ViewUpdater(ScheduledExecutorService executor)

Method Detail

notifyOfAddedView

public void notifyOfAddedView(View view)

Notifies this ViewUpdater of a new metric that should be regularly updated.

Parameters:

view - metric that should be regularly updated

notifyOfRemovedView

public void notifyOfRemovedView(View view)

Notifies this ViewUpdater of a metric that should no longer be regularly updated.

Parameters:

view - metric that should no longer be regularly updated