Class: Fluent::ExplodeFilter

Inherits:
Filter
  • Object
show all
Defined in:
lib/fluent/plugin/filter_explode.rb

Instance Method Summary collapse

Instance Method Details

#filter(tag, time, record) ⇒ Object 



8
9
10
11
12
13
14
15
16
17
 
# File 'lib/fluent/plugin/filter_explode.rb', line 8

def filter(tag, time, record)
  event = Fluent::PluginMixin::MutateEvent.new(record, expand_nesting:false)
  event_data = Fluent::PluginMixin::MutateEvent.new({}, expand_nesting:true)

  event.keys.each do |key|
    event_data.set(key, event.get(key))
  end

  event_data.to_record
end