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