Sha256: c0b8f4b852d92537b7dd9a2a6f2dccbff00918b4be7139fca063749ddc928d60
Contents?: true
Size: 511 Bytes
Versions: 10
Compression:
Stored size: 511 Bytes
Contents
#!/usr/bin/env ruby
require 'wukong'
require 'wukong/streamer/summing_reducer'
#
#
class Summer < Wukong::Streamer::SummingReducer
attr_accessor :sample_line
def initialize *args
self.summing_elements = [0]
super *args
end
def start! *args
self.sample_line = args
super *args
end
def get_key *fields
fields.values_at(2,3)
end
def finalize
summing_elements.each{|idx| sample_line[idx] = sums[idx]}
yield sample_line
end
end
Wukong::Script.new(Summer, nil).run
Version data entries
10 entries across 10 versions & 2 rubygems