Module: Elasticsearch::Model::MongoidExtensions::Importing

Included in:
Adapter::Mongoid::Importing
Defined in:
lib/elasticsearch/model/mongoid_extensions/importing.rb

Instance Method Summary collapse

Instance Method Details

#__find_in_batches(options = {}) ⇒ Object 



7
8
9
10
11
12
13
14
 
# File 'lib/elasticsearch/model/mongoid_extensions/importing.rb', line 7

def __find_in_batches(options = {})
  batch_size = options.fetch(:batch_size, 1_000)
  base_criteria = options.fetch(:criteria, all)

  base_criteria.no_timeout.each_slice(batch_size) do |items|
    yield items
  end
end