Method: Aerospike::BatchOperateNode.generate_list

Defined in:
lib/aerospike/command/batch_operate_node.rb

.generate_list(cluster, replica_policy, records) ⇒ Object

[View source]

24
25
26
27
28
 
# File 'lib/aerospike/command/batch_operate_node.rb', line 24

def self.generate_list(cluster, replica_policy, records)
  records.each_with_index
         .group_by { |record, _| cluster.get_node_for_key(replica_policy, record.key, is_write: record.has_write) }
         .map { |node, records_with_idx| BatchOperateNode.new(node, records_with_idx) }
end