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

      • MeanReducer

        public MeanReducer()
    • Method Detail

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