# File lib/fluent/plugin/exec_util.rb, line 16definitialize(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 21defcall(io)
io.each_line(&method(:each_line))
end
each_line(line)click to toggle source
# File lib/fluent/plugin/exec_util.rb, line 25defeach_line(line)
line.chomp!vals = line.split("\t")
record = Hash[@keys.zip(vals)]
@on_message.call(record)
end