Package org.apache.nemo.runtime.common.metric

Class StageMetric

java.lang.Object

org.apache.nemo.runtime.common.metric.StageMetric

All Implemented Interfaces:

Metric, StateMetric<StageState.State>

public class StageMetric
extends java.lang.Object
implements StateMetric<StageState.State>

Metric class for Stage.

Constructor Summary

Constructors

Constructor	Description
StageMetric(java.lang.String id)
StageMetric(Stage stage)

Method Summary

Modifier and Type	Method	Description
void	addEvent(StageState.State prevState, StageState.State newState)	Add a StateTransitionEvent to the metric.
java.lang.String	getId()	Get its unique id.
java.util.List<StateTransitionEvent<StageState.State>>	getStateTransitionEvents()	Get its list of StateTransitionEvent.
boolean	processMetricMessage(java.lang.String metricField, byte[] metricValue)	Process metric message from evaluators.

Methods inherited from class java.lang.Object

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

Constructor Detail

StageMetric

public StageMetric(Stage stage)

StageMetric

public StageMetric(java.lang.String id)

Method Detail

getId

public final java.lang.String getId()

Description copied from interface: Metric

Get its unique id.

Specified by:

getId in interface Metric

Returns:

an unique id

getStateTransitionEvents

public final java.util.List<StateTransitionEvent<StageState.State>> getStateTransitionEvents()

Description copied from interface: StateMetric

Get its list of StateTransitionEvent.

Specified by:

getStateTransitionEvents in interface StateMetric<StageState.State>

Returns:

list of events.

addEvent

public final void addEvent(StageState.State prevState,
                           StageState.State newState)

Description copied from interface: StateMetric

Add a StateTransitionEvent to the metric.

Specified by:

addEvent in interface StateMetric<StageState.State>

Parameters:

prevState - previous state.

newState - new state.

processMetricMessage

public final boolean processMetricMessage(java.lang.String metricField,
                                          byte[] metricValue)

Description copied from interface: Metric

Process metric message from evaluators.

Specified by:

processMetricMessage in interface Metric

Parameters:

metricField - field name of the metric.

metricValue - byte array of serialized data value.

Returns:

true if the metric was changed or false if not.