class Fluent::FlattenHashOutput
Public Class Methods
new()
click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_flatten_hash.rb, line 13 def initialize super end
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_flatten_hash.rb, line 17 def configure(conf) super if (!@tag && !remove_tag_prefix && !remove_tag_suffix && !add_tag_prefix && !add_tag_suffix ) raise ConfigError, "out_flatten_hash: No tag parameters are set" end end
emit(tag, es, chain)
click to toggle source
# File lib/fluent/plugin/out_flatten_hash.rb, line 28 def emit(tag, es, chain) tag = @tag || tag es.each do |time, record| record = flatten_record(record, []) t = tag.dup filter_record(t, time, record) router.emit(t, time, record) end chain.next end