Execute query, apply statement's aggregation function, and return result iterator. The query
executor puts results on a queue in separate threads. The calling thread concurrently pops
results off the queue through the result iterator.
Namespace: Aerospike.ClientThe aggregation function is called on both server and client (final reduce). Therefore, the Lua script files must also reside on both server and client. The package name is used to locate the udf file location:
udf file = <udf dir>/<package name>.lua
This method is only supported by Aerospike 3 servers.
Assembly: AerospikeClient (in AerospikeClient.dll) Version: 3.0.0.0 (3.0.0)
Syntax
Parameters
- policy
- Type: QueryPolicy
generic configuration parameters, pass in null for defaults
- statement
- Type: Aerospike.Client Statement
database query command
- packageName
- Type:
System String
server package where user defined function resides
- functionName
- Type:
System String
aggregation function name
- functionArgs
- Type: Aerospike.Client Value
arguments to pass to function name, if any
Exceptions
Exception | Condition |
---|---|
Aerospike.Client AerospikeException | if query fails |
See Also