Execute query, apply statement's aggregation function, and return result iterator.
The aggregation function should be initialized via the statement's SetAggregateFunction()
and should be located in a Lua resource file located in an assembly.
Namespace: Aerospike.ClientThe query executor puts results on a queue in separate threads. The calling thread concurrently pops results off the queue through the ResultSet iterator. The aggregation function is called on both server and client (final reduce). Therefore, the Lua script file must also reside on both server and client.
This method is only supported by Aerospike 3 servers.
Assembly: AerospikeClient (in AerospikeClient.dll) Version: 3.2.0.0 (3.2.1)
Syntax
Parameters
- policy
- Type: Aerospike.Client QueryPolicy
generic configuration parameters, pass in null for defaults
- statement
- Type: Aerospike.Client Statement
database query command with aggregate functions already initialized by SetAggregateFunction()
Exceptions
Exception | Condition |
---|---|
Aerospike.Client AerospikeException | if query fails |
See Also