AerospikeClientQueryAggregate Method (QueryPolicy, Statement)

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

Namespace:  Aerospike.Client
Assembly:  AerospikeClient (in AerospikeClient.dll) Version: 5.1.1.0 (5.1.1)
Syntax
C#
Copy
public ResultSet QueryAggregate(
	QueryPolicy policy,
	Statement statement
)

Parameters

policy
Type: Aerospike.ClientQueryPolicy
query configuration parameters, pass in null for defaults
statement
Type: Aerospike.ClientStatement
query definition with aggregate functions already initialized by SetAggregateFunction().

Return Value

Type: ResultSet

Implements

IAerospikeClientQueryAggregate(QueryPolicy, Statement)
Exceptions
ExceptionCondition
AerospikeExceptionif query fails
See Also

Reference

AerospikeClient Class
QueryAggregate Overload
Aerospike.Client Namespace