Class: Fluent::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 



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

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