Class: Fluent::Plugin::TraildbOutput

Inherits:
Output
  • Object
show all
Defined in:
lib/fluent/plugin/out_traildb.rb

Instance Method Summary collapse

Instance Method Details

#write(chunk) ⇒ Object 



13
14
15
16
17
18
19
20
21
 
# 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