Package org.apache.nemo.runtime.master.metric

Class MetricManagerMaster

java.lang.Object

org.apache.nemo.runtime.master.metric.MetricManagerMaster

All Implemented Interfaces:

MetricMessageHandler

public final class MetricManagerMaster
extends java.lang.Object
implements MetricMessageHandler

A default metric message handler.

Method Summary

Modifier and Type	Method	Description
void	onMetricMessageReceived(java.lang.String metricType, java.lang.String metricId, java.lang.String metricField, byte[] metricValue)	Handle the received metric message.
void	sendMetricFlushRequest()
void	terminate()	Cleans up and terminates this handler.

Methods inherited from class java.lang.Object

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

Method Detail

sendMetricFlushRequest

public void sendMetricFlushRequest()

onMetricMessageReceived

public void onMetricMessageReceived(java.lang.String metricType,
                                    java.lang.String metricId,
                                    java.lang.String metricField,
                                    byte[] metricValue)

Description copied from interface: MetricMessageHandler

Handle the received metric message.

Specified by:

onMetricMessageReceived in interface MetricMessageHandler

Parameters:

metricType - a given type for the metric (ex. TaskMetric).

metricId - id of the metric.

metricField - field name of the metric.

metricValue - serialized metric data value.

terminate

public void terminate()

Description copied from interface: MetricMessageHandler

Cleans up and terminates this handler.

Specified by:

terminate in interface MetricMessageHandler