IAerospikeClientQueryAggregate(QueryPolicy, Statement) Method

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.

The 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.

Definition

Namespace: Aerospike.Client
Assembly: AerospikeClient (in AerospikeClient.dll) Version: 7.0.1
C#
ResultSet QueryAggregate(
	QueryPolicy policy,
	Statement statement
)

Parameters

policy  QueryPolicy
query configuration parameters, pass in null for defaults
statement  Statement
query definition with aggregate functions already initialized by SetAggregateFunction().

Return Value

ResultSet

Exceptions

AerospikeExceptionif query fails

See Also