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