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