Method: Fluent::Plugin::ElasticsearchInput#run

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

#run ⇒ Object 



260
261
262
263
264
265
266
267
268
269
270
 
# File 'lib/fluent/plugin/in_elasticsearch.rb', line 260

def run
  return run_slice if @num_slices <= 1

  log.warn("Large slice number is specified:(#{@num_slices}). Consider reducing num_slices") if @num_slices > 8

  @num_slices.times.map do |slice_id|
    thread_create(:"in_elasticsearch_thread_#{slice_id}") do
      run_slice(slice_id)
    end
  end
end