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.2.8	lib/reducers/max_reducer.rb
trafficbroker-mandy-0.2	lib/reducers/max_reducer.rb
mandy-0.5.28	lib/mandy/reducers/max_reducer.rb
mandy-0.5.27	lib/mandy/reducers/max_reducer.rb
mandy-0.5.26	lib/mandy/reducers/max_reducer.rb
mandy-0.5.25	lib/mandy/reducers/max_reducer.rb
mandy-0.5.24	lib/mandy/reducers/max_reducer.rb
mandy-0.5.23	lib/mandy/reducers/max_reducer.rb
mandy-0.5.22	lib/mandy/reducers/max_reducer.rb
mandy-0.5.21	lib/mandy/reducers/max_reducer.rb
mandy-0.5.20	lib/mandy/reducers/max_reducer.rb
mandy-0.5.19	lib/mandy/reducers/max_reducer.rb
mandy-0.5.17	lib/mandy/reducers/max_reducer.rb
mandy-0.5.14	lib/mandy/reducers/max_reducer.rb
mandy-0.5.13	lib/mandy/reducers/max_reducer.rb
mandy-0.5.11	lib/mandy/reducers/max_reducer.rb
mandy-0.5.10	lib/mandy/reducers/max_reducer.rb
mandy-0.5.9	lib/mandy/reducers/max_reducer.rb
mandy-0.5.8	lib/mandy/reducers/max_reducer.rb
mandy-0.5.7	lib/mandy/reducers/max_reducer.rb