Package | Description |
---|---|
com.aerospike.client | |
com.aerospike.client.async | |
com.aerospike.client.task |
Modifier and Type | Method and Description |
---|---|
ExecuteTask |
AerospikeClient.execute(WritePolicy policy,
Statement statement,
String packageName,
String functionName,
Value... functionArgs)
Apply user defined function on records that match the statement filter.
|
ExecuteTask |
IAerospikeClient.execute(WritePolicy policy,
Statement statement,
String packageName,
String functionName,
Value... functionArgs)
Apply user defined function on records that match the statement filter.
|
void |
AerospikeClient.query(EventLoop eventLoop,
RecordSequenceListener listener,
QueryPolicy policy,
Statement statement)
Asynchronously execute query on all server nodes.
|
void |
IAerospikeClient.query(EventLoop eventLoop,
RecordSequenceListener listener,
QueryPolicy policy,
Statement statement)
Asynchronously execute query on all server nodes.
|
RecordSet |
AerospikeClient.query(QueryPolicy policy,
Statement statement)
Execute query on all server nodes and return record iterator.
|
RecordSet |
IAerospikeClient.query(QueryPolicy policy,
Statement statement)
Execute query on all server nodes and return record iterator.
|
ResultSet |
AerospikeClient.queryAggregate(QueryPolicy policy,
Statement statement)
Execute query, apply statement's aggregation function, and return result iterator.
|
ResultSet |
IAerospikeClient.queryAggregate(QueryPolicy policy,
Statement statement)
Execute query, apply statement's aggregation function, and return result iterator.
|
ResultSet |
AerospikeClient.queryAggregate(QueryPolicy policy,
Statement statement,
String packageName,
String functionName,
Value... functionArgs)
Execute query, apply statement's aggregation function, and return result iterator.
|
ResultSet |
IAerospikeClient.queryAggregate(QueryPolicy policy,
Statement statement,
String packageName,
String functionName,
Value... functionArgs)
Execute query, apply statement's aggregation function, and return result iterator.
|
ResultSet |
AerospikeClient.queryAggregateNode(QueryPolicy policy,
Statement statement,
Node node)
Execute query on a single server node, apply statement's aggregation function, and return
result iterator.
|
ResultSet |
IAerospikeClient.queryAggregateNode(QueryPolicy policy,
Statement statement,
Node node)
Execute query on a single server node, apply statement's aggregation function, and return
result iterator.
|
RecordSet |
AerospikeClient.queryNode(QueryPolicy policy,
Statement statement,
Node node)
Execute query on a single server node and return record iterator.
|
RecordSet |
IAerospikeClient.queryNode(QueryPolicy policy,
Statement statement,
Node node)
Execute query on a single server node and return record iterator.
|
Modifier and Type | Method and Description |
---|---|
void |
AsyncClient.query(QueryPolicy policy,
RecordSequenceListener listener,
Statement statement)
Asynchronously execute query on all server nodes.
|
void |
IAsyncClient.query(QueryPolicy policy,
RecordSequenceListener listener,
Statement statement)
Asynchronously execute query on all server nodes.
|
Constructor and Description |
---|
ExecuteTask(com.aerospike.client.cluster.Cluster cluster,
Policy policy,
Statement statement)
Initialize task with fields needed to query server nodes.
|
Copyright ? 2012–2018 Aerospike, Inc. All rights reserved.