class Fluent::Plugin::TraildbOutput

Public Instance Methods

write(chunk) click to toggle source
# File lib/fluent/plugin/out_traildb.rb, line 13
def write(chunk)
  cons = Traildb::TrailDBConstructor.new(@path+dump_unique_id_hex(chunk.unique_id), @fields)
  chunk.each do |time, record|
    uuid = record[@uuid_key]
    values = @fields.map{|f|record[f]}
    cons.add(uuid, time.to_i, values)
  end
  cons.finalize
end