# File lib/fluent/plugin/exec_util.rb, line 32definitialize(keys, on_message)
@keys = keyssuper(on_message)
end
Public Instance Methods
call(io)click to toggle source
# File lib/fluent/plugin/exec_util.rb, line 37defcall(io)
io.each_line(&method(:each_line))
end
each_line(line)click to toggle source
# File lib/fluent/plugin/exec_util.rb, line 41defeach_line(line)
line.chomp!vals = line.split("\t")
record = Hash[@keys.zip(vals)]
@on_message.call(record)
end