Contents

module Mandy
  module Reducers
    class MaxReducer < Base
      def reducer(key,values)
        values.map! {|value| value.to_f}
        emit(key, values.max)
      end
    end
  end
end

Version data entries

92 entries across 92 versions & 2 rubygems

Version	Path
trafficbroker-mandy-0.1.6	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.1.7	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.1.8	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.1.9	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.2.10	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.2.11	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.2.12	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.2.13	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.2.2	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.2.3	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.2.4.2	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.2.4.3	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.2.4.4	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.2.4.5	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.2.4.6	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.2.4	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.2.5.1	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.2.5	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.2.6	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.2.7	lib/reducers/max_reducer.rb