Package org.apache.storm.metric.api.rpc

Class ReducedShellMetric

java.lang.Object

org.apache.storm.metric.api.ReducedMetric

org.apache.storm.metric.api.rpc.ReducedShellMetric

All Implemented Interfaces:

IMetric, IShellMetric

public class ReducedShellMetric
extends ReducedMetric
implements IShellMetric

Constructor Summary

Constructors

Constructor	Description
ReducedShellMetric(IReducer reducer)

Method Summary

Modifier and Type	Method	Description
void	updateMetricFromRPC(Object value)	This interface is used by ShellBolt and ShellSpout through RPC call to update Metric.

Methods inherited from class org.apache.storm.metric.api.ReducedMetric

getValueAndReset, update

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.storm.metric.api.IMetric

getValueAndReset

Constructor Details

ReducedShellMetric

public ReducedShellMetric(IReducer reducer)

Method Details

updateMetricFromRPC

public void updateMetricFromRPC(Object value)

Description copied from interface: IShellMetric

This interface is used by ShellBolt and ShellSpout through RPC call to update Metric.

Specified by:

updateMetricFromRPC in interface IShellMetric

Parameters:

value - used to update metric, its's meaning change according implementation Object can be any json support types: String, Long, Double, Boolean, Null, List, Map