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 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