Sha256: 248ab01e70b5c2a7407a9540e0a9378851aca0aeb13aed0486c728b70e341220

Contents?: true

Size: 757 Bytes

Versions: 4

Compression:

Stored size: 757 Bytes

Contents

module CassandraObject
  class Scope
    module Batches
      def find_each(options = {})
        find_in_batches(options) do |records|
          records.each { |record| yield record }
        end
      end

      def find_in_batches(options = {})
        batch_size = options.delete(:batch_size) || 1000
        start_key = nil

        scope = limit(batch_size + 1)
        records = scope.to_a

        while records.any?
          if records.size > batch_size
            next_record = records.pop
          else
             next_record = nil
          end

          yield records
          break if next_record.nil?

          records = scope.where("#{adapter.primary_key_column} >= '#{next_record.id}'").to_a
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
gotime-cassandra_object-4.12.2 lib/cassandra_object/scope/batches.rb
gotime-cassandra_object-4.12.1 lib/cassandra_object/scope/batches.rb
gotime-cassandra_object-4.12.0 lib/cassandra_object/scope/batches.rb
gotime-cassandra_object-4.11.6 lib/cassandra_object/scope/batches.rb