Class: Fluent::Plugin::EverySenseFilter

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

Overview

EverySenseFilter Split EverySense data into multiple output entries to store each datum separately

Instance Method Summary collapse

Instance Method Details

#filter_stream(tag, es) ⇒ Object 



11
12
13
14
15
16
17
18
 
# File 'lib/fluent/plugin/filter_everysense.rb', line 11

def filter_stream(tag, es)
  new_es = Fluent::MultiEventStream.new
  es.each do |time, record|
    # log.debug "filter_everysense: #{record}"
    split_record(time, record, new_es)
  end
  new_es
end