Method: Fluent::Plugin::ElasticsearchInput#process_next_scroll_request

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

#process_next_scroll_request(es, scroll_id) ⇒ Object 



300
301
302
303
304
 
# File 'lib/fluent/plugin/in_elasticsearch.rb', line 300

def process_next_scroll_request(es, scroll_id)
  result = process_scroll_request(scroll_id)
  result['hits']['hits'].each { |hit| process_events(hit, es) }
  {'has_hits' => result['hits']['hits'].any?, '_scroll_id' => result['_scroll_id']}
end