IAsyncClientQueryPartitions Method

Aerospike
Overload List

  NameDescription
Public methodQueryPartitions(QueryPolicy, Statement, PartitionFilter)
Execute query for specified partitions and return record iterator. The query executor puts records on a queue in separate threads. The calling thread concurrently pops records off the queue through the record iterator.

Requires server version 6.0+ if using a secondary index query.

(Inherited from IAerospikeClient.)
Public methodQueryPartitions(QueryPolicy, RecordSequenceListener, Statement, PartitionFilter)
Asynchronously execute query for specified partitions. The query policy's
maxConcurrentNodes
dictate how many nodes can be queried in parallel. The default is to query all nodes in parallel.

This method schedules the node's query commands with channel selectors and returns. Selector threads will process the commands and send the results to the listener.

Each record result is returned in separate OnRecord() calls.

Requires server version 6.0+ if using a secondary index query.

Top
See Also

Reference