Module: Elasticsearch::Model::Adapter::Mongoid::Importing

Defined in:
lib/elasticsearch/model/adapters/mongoid.rb

Instance Method Summary collapse

Instance Method Details

#__find_in_batches(options = {}, &block) ⇒ Object

Fetch batches of records from the database

See Also:



65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
 
# File 'lib/elasticsearch/model/adapters/mongoid.rb', line 65

def __find_in_batches(options={}, &block)
  options[:batch_size] ||= 1_000
  items = []

  all.each do |item|
    items << item

    if items.length % options[:batch_size] == 0
      yield items
      items = []
    end
  end

  unless items.empty?
    yield items
  end
end

#__transform ⇒ Object 



83
84
85
 
# File 'lib/elasticsearch/model/adapters/mongoid.rb', line 83

def __transform
  lambda {|a|  { index: { _id: a.id.to_s, data: a.as_indexed_json } }}
end