class Fluent::Compat::ExecUtil::TSVParser
Public Class Methods
new(keys, on_message)
click to toggle source
Calls superclass method
Fluent::Compat::ExecUtil::Parser::new
# File lib/fluent/compat/exec_util.rb, line 59 def initialize(keys, on_message) @keys = keys super(on_message) end
Public Instance Methods
call(io)
click to toggle source
# File lib/fluent/compat/exec_util.rb, line 64 def call(io) io.each_line(&method(:each_line)) end
each_line(line)
click to toggle source
# File lib/fluent/compat/exec_util.rb, line 68 def each_line(line) line.chomp! vals = line.split("\t") record = Hash[@keys.zip(vals)] @on_message.call(record) end