Method: Fluent::Plugin::GriddbOutput#process

Defined in:
lib/fluent/plugin/out_griddb.rb

#process(tag, es) ⇒ Object

Overwrite when Not use buffer



102
103
104
105
106
107
 
# File 'lib/fluent/plugin/out_griddb.rb', line 102

def process(tag, es)
  es.each do |time, record|    
      arrays_2 = convert(record)
    handle_record(tag, time, arrays_2)
  end
end