Class MeanReducer

java.lang.Object
org.apache.storm.metric.api.MeanReducer
All Implemented Interfaces:
IReducer<org.apache.storm.metric.api.MeanReducerState>

public class MeanReducer extends Object implements IReducer<org.apache.storm.metric.api.MeanReducerState>
  • Constructor Details

    • MeanReducer

      public MeanReducer()
  • Method Details

    • init

      public org.apache.storm.metric.api.MeanReducerState init()
      Specified by:
      init in interface IReducer<org.apache.storm.metric.api.MeanReducerState>
    • reduce

      public org.apache.storm.metric.api.MeanReducerState reduce(org.apache.storm.metric.api.MeanReducerState acc, Object input)
      Specified by:
      reduce in interface IReducer<org.apache.storm.metric.api.MeanReducerState>
    • extractResult

      public Object extractResult(org.apache.storm.metric.api.MeanReducerState acc)
      Specified by:
      extractResult in interface IReducer<org.apache.storm.metric.api.MeanReducerState>