# File lib/fluent/plugin/out_exec_filter.rb, line 402definitialize(out_keys, on_message)
@out_keys = out_keyssuper(on_message)
end
Public Instance Methods
call(io)click to toggle source
# File lib/fluent/plugin/out_exec_filter.rb, line 407defcall(io)
io.each_line(&method(:each_line))
end
each_line(line)click to toggle source
# File lib/fluent/plugin/out_exec_filter.rb, line 411defeach_line(line)
line.chomp!vals = line.split("\t")
record = Hash[@out_keys.zip(vals)]
@on_message.call(record)
end