AsyncClient (aerospike-client 4.2.1 API)

java.lang.Object
- com.aerospike.client.AerospikeClient
- - com.aerospike.client.async.AsyncClient

All Implemented Interfaces:

IAsyncClient, IAerospikeClient, Closeable, AutoCloseable
```
public class AsyncClient
extends AerospikeClient
implements IAsyncClient, Closeable
```
THIS CLASS IS OBSOLETE.
The new efficient asynchronous API is located directly in AerospikeClient. This class is just a thin wrapper over the new AerospikeClient asynchronous API. This class exists solely to provide compatibility with legacy applications.
Asynchronous Aerospike client.
Your application uses this class to perform asynchronous database operations such as writing and reading records, and selecting sets of records. Write operations include specialized functionality such as append/prepend and arithmetic addition.
This client is thread-safe. One client instance should be used per cluster. Multiple threads should share this cluster instance.
Each record may have multiple bins, unless the Aerospike server nodes are configured as "single-bin". In "multi-bin" mode, partial records may be written or read by specifying the relevant subset of bins.

Field Summary

Fields
Modifier and Type	Field and Description
`BatchPolicy`	`asyncBatchPolicyDefault` Default batch policy that is used when asynchronous batch command policy is null.
`QueryPolicy`	`asyncQueryPolicyDefault` Default query policy that is used when asynchronous query command policy is null.
`Policy`	`asyncReadPolicyDefault` Default read policy that is used when asynchronous read command policy is null.
`ScanPolicy`	`asyncScanPolicyDefault` Default scan policy that is used when asynchronous scan command policy is null.
`WritePolicy`	`asyncWritePolicyDefault` Default write policy that is used when asynchronous write command policy is null.

Fields inherited from class com.aerospike.client.AerospikeClient
batchPolicyDefault, infoPolicyDefault, queryPolicyDefault, readPolicyDefault, scanPolicyDefault, writePolicyDefault

Constructor Summary

Constructors
Constructor and Description
`AsyncClient(AsyncClientPolicy policy, Host... hosts)` Initialize asynchronous client with suitable hosts to seed the cluster map.
`AsyncClient(AsyncClientPolicy policy, String hostname, int port)` Initialize asynchronous client.
`AsyncClient(String hostname, int port)` Initialize asynchronous client.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`add(WritePolicy policy, WriteListener listener, Key key, Bin... bins)` Asynchronously add integer bin values to existing record bin values.
`void`	`append(WritePolicy policy, WriteListener listener, Key key, Bin... bins)` Asynchronously append bin string values to existing record bin values.
`void`	`close()` Close all client connections to database server nodes.
`void`	`delete(WritePolicy policy, DeleteListener listener, Key key)` Asynchronously delete record for specified key.
`void`	`execute(WritePolicy policy, ExecuteListener listener, Key key, String packageName, String functionName, Value... functionArgs)` Asynchronously execute user defined function on server and return results.
`void`	`exists(BatchPolicy policy, ExistsArrayListener listener, Key[] keys)` Asynchronously check if multiple record keys exist in one batch call.
`void`	`exists(BatchPolicy policy, ExistsSequenceListener listener, Key[] keys)` Asynchronously check if multiple record keys exist in one batch call.
`void`	`exists(Policy policy, ExistsListener listener, Key key)` Asynchronously determine if a record key exists.
`void`	`get(BatchPolicy policy, BatchListListener listener, List<BatchRead> records)` Asynchronously read multiple records for specified batch keys in one batch call.
`void`	`get(BatchPolicy policy, BatchSequenceListener listener, List<BatchRead> records)` Asynchronously read multiple records for specified batch keys in one batch call.
`void`	`get(BatchPolicy policy, RecordArrayListener listener, Key[] keys)` Asynchronously read multiple records for specified keys in one batch call.
`void`	`get(BatchPolicy policy, RecordArrayListener listener, Key[] keys, String... binNames)` Asynchronously read multiple record headers and bins for specified keys in one batch call.
`void`	`get(BatchPolicy policy, RecordSequenceListener listener, Key[] keys)` Asynchronously read multiple records for specified keys in one batch call.
`void`	`get(BatchPolicy policy, RecordSequenceListener listener, Key[] keys, String... binNames)` Asynchronously read multiple record headers and bins for specified keys in one batch call.
`void`	`get(Policy policy, RecordListener listener, Key key)` Asynchronously read entire record for specified key.
`void`	`get(Policy policy, RecordListener listener, Key key, String... binNames)` Asynchronously read record header and bins for specified key.
`BatchPolicy`	`getAsyncBatchPolicyDefault()`
`QueryPolicy`	`getAsyncQueryPolicyDefault()`
`Policy`	`getAsyncReadPolicyDefault()`
`ScanPolicy`	`getAsyncScanPolicyDefault()`
`WritePolicy`	`getAsyncWritePolicyDefault()`
`void`	`getHeader(BatchPolicy policy, RecordArrayListener listener, Key[] keys)` Asynchronously read multiple record header data for specified keys in one batch call.
`void`	`getHeader(BatchPolicy policy, RecordSequenceListener listener, Key[] keys)` Asynchronously read multiple record header data for specified keys in one batch call.
`void`	`getHeader(Policy policy, RecordListener listener, Key key)` Asynchronously read record generation and expiration only for specified key.
`void`	`operate(WritePolicy policy, RecordListener listener, Key key, Operation... operations)` Asynchronously perform multiple read/write operations on a single key in one batch call.
`void`	`prepend(WritePolicy policy, WriteListener listener, Key key, Bin... bins)` Asynchronously prepend bin string values to existing record bin values.
`void`	`put(WritePolicy policy, WriteListener listener, Key key, Bin... bins)` Asynchronously write record bin(s).
`void`	`query(QueryPolicy policy, RecordSequenceListener listener, Statement statement)` Asynchronously execute query on all server nodes.
`void`	`scanAll(ScanPolicy policy, RecordSequenceListener listener, String namespace, String setName, String... binNames)` Asynchronously read all records in specified namespace and set.
`void`	`touch(WritePolicy policy, WriteListener listener, Key key)` Asynchronously create record if it does not already exist.

Methods inherited from class com.aerospike.client.AerospikeClient
add, add, append, append, changePassword, createIndex, createIndex, createRole, createUser, delete, delete, dropIndex, dropRole, dropUser, execute, execute, execute, exists, exists, exists, exists, exists, get, get, get, get, get, get, get, get, get, get, get, get, get, getBatchPolicyDefault, getClusterStats, getHeader, getHeader, getHeader, getHeader, getHeader, getInfoPolicyDefault, getNode, getNodeNames, getNodes, getQueryPolicyDefault, getReadPolicyDefault, getScanPolicyDefault, getWritePolicyDefault, grantPrivileges, grantRoles, isConnected, operate, operate, prepend, prepend, put, put, query, query, queryAggregate, queryAggregate, queryAggregateNode, queryNode, queryRole, queryRoles, queryUser, queryUsers, register, register, registerUdfString, removeUdf, revokePrivileges, revokeRoles, scanAll, scanAll, scanNode, scanNode, touch, touch, truncate

Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.aerospike.client.IAerospikeClient
add, add, append, append, changePassword, createIndex, createIndex, createRole, createUser, delete, delete, dropIndex, dropRole, dropUser, execute, execute, execute, exists, exists, exists, exists, exists, get, get, get, get, get, get, get, get, get, get, get, get, get, getBatchPolicyDefault, getClusterStats, getHeader, getHeader, getHeader, getHeader, getHeader, getInfoPolicyDefault, getNode, getNodeNames, getNodes, getQueryPolicyDefault, getReadPolicyDefault, getScanPolicyDefault, getWritePolicyDefault, grantPrivileges, grantRoles, isConnected, operate, operate, prepend, prepend, put, put, query, query, queryAggregate, queryAggregate, queryAggregateNode, queryNode, queryRole, queryRoles, queryUser, queryUsers, register, register, registerUdfString, removeUdf, revokePrivileges, revokeRoles, scanAll, scanAll, scanNode, scanNode, touch, touch, truncate

- Field Detail
  - asyncReadPolicyDefault
```
public final Policy asyncReadPolicyDefault
```
    Default read policy that is used when asynchronous read command policy is null.
  - asyncWritePolicyDefault
```
public final WritePolicy asyncWritePolicyDefault
```
    Default write policy that is used when asynchronous write command policy is null.
  - asyncScanPolicyDefault
```
public final ScanPolicy asyncScanPolicyDefault
```
    Default scan policy that is used when asynchronous scan command policy is null.
  - asyncQueryPolicyDefault
```
public final QueryPolicy asyncQueryPolicyDefault
```
    Default query policy that is used when asynchronous query command policy is null.
  - asyncBatchPolicyDefault
```
public final BatchPolicy asyncBatchPolicyDefault
```
    Default batch policy that is used when asynchronous batch command policy is null.
- Constructor Detail
  - AsyncClient
```
public AsyncClient(String hostname,
                   int port)
            throws AerospikeException
```
    Initialize asynchronous client. If the host connection succeeds, the client will:
    - Add host to the cluster map
    - Request host's list of other nodes in cluster
    - Add these nodes to cluster map
    
    If the connection succeeds, the client is ready to process database requests. If the connection fails, the cluster will remain in a disconnected state until the server is activated.
    
    Parameters:
    
    hostname - host name
    
    port - host port
    
    Throws:
    
    AerospikeException - if host connection fails
  - AsyncClient
```
public AsyncClient(AsyncClientPolicy policy,
                   String hostname,
                   int port)
            throws AerospikeException
```
    Initialize asynchronous client. The client policy is used to set defaults and size internal data structures. If the host connection succeeds, the client will:
    - Add host to the cluster map
    - Request host's list of other nodes in cluster
    - Add these nodes to cluster map
    
    If the connection succeeds, the client is ready to process database requests. If the connection fails and the policy's failIfNotConnected is true, a connection exception will be thrown. Otherwise, the cluster will remain in a disconnected state until the server is activated.
    
    Parameters:
    
    policy - client configuration parameters, pass in null for defaults
    
    hostname - host name
    
    port - host port
    
    Throws:
    
    AerospikeException - if host connection fails
  - AsyncClient
```
public AsyncClient(AsyncClientPolicy policy,
                   Host... hosts)
            throws AerospikeException
```
    Initialize asynchronous client with suitable hosts to seed the cluster map. The client policy is used to set defaults and size internal data structures. For each host connection that succeeds, the client will:
    - Add host to the cluster map
    - Request host's list of other nodes in cluster
    - Add these nodes to cluster map
    
    In most cases, only one host is necessary to seed the cluster. The remaining hosts are added as future seeds in case of a complete network failure.
    If one connection succeeds, the client is ready to process database requests. If all connections fail and the policy's failIfNotConnected is true, a connection exception will be thrown. Otherwise, the cluster will remain in a disconnected state until the server is activated.
    
    Parameters:
    
    policy - client configuration parameters, pass in null for defaults
    
    hosts - array of potential hosts to seed the cluster
    
    Throws:
    
    AerospikeException - if all host connections fail
- Method Detail
  - close
```
public final void close()
```
    Close all client connections to database server nodes.
    
    Specified by:
    
    close in interface IAerospikeClient
    
    Specified by:
    
    close in interface Closeable
    
    Specified by:
    
    close in interface AutoCloseable
    
    Overrides:
    
    close in class AerospikeClient
  - getAsyncReadPolicyDefault
```
public final Policy getAsyncReadPolicyDefault()
```
    Specified by:
    
    getAsyncReadPolicyDefault in interface IAsyncClient
  - getAsyncWritePolicyDefault
```
public final WritePolicy getAsyncWritePolicyDefault()
```
    Specified by:
    
    getAsyncWritePolicyDefault in interface IAsyncClient
  - getAsyncScanPolicyDefault
```
public final ScanPolicy getAsyncScanPolicyDefault()
```
    Specified by:
    
    getAsyncScanPolicyDefault in interface IAsyncClient
  - getAsyncQueryPolicyDefault
```
public final QueryPolicy getAsyncQueryPolicyDefault()
```
    Specified by:
    
    getAsyncQueryPolicyDefault in interface IAsyncClient
  - getAsyncBatchPolicyDefault
```
public final BatchPolicy getAsyncBatchPolicyDefault()
```
    Specified by:
    
    getAsyncBatchPolicyDefault in interface IAsyncClient
  - put
```
public final void put(WritePolicy policy,
                      WriteListener listener,
                      Key key,
                      Bin... bins)
               throws AerospikeException
```
    Asynchronously write record bin(s). This method schedules the put command with a channel selector and returns. Another thread will process the command and send the results to the listener.
    The policy specifies the transaction timeout, record expiration and how the transaction is handled when the record already exists.
    
    Specified by:
    
    put in interface IAsyncClient
    
    Parameters:
    
    policy - write configuration parameters, pass in null for defaults
    
    listener - where to send results, pass in null for fire and forget
    
    key - unique record identifier
    
    bins - array of bin name/value pairs
    
    Throws:
    
    AerospikeException - if queue is full
  - append
```
public final void append(WritePolicy policy,
                         WriteListener listener,
                         Key key,
                         Bin... bins)
                  throws AerospikeException
```
    Asynchronously append bin string values to existing record bin values. This method schedules the append command with a channel selector and returns. Another thread will process the command and send the results to the listener.
    The policy specifies the transaction timeout, record expiration and how the transaction is handled when the record already exists. This call only works for string values.
    
    Specified by:
    
    append in interface IAsyncClient
    
    Parameters:
    
    policy - write configuration parameters, pass in null for defaults
    
    listener - where to send results, pass in null for fire and forget
    
    key - unique record identifier
    
    bins - array of bin name/value pairs
    
    Throws:
    
    AerospikeException - if queue is full
  - prepend
```
public final void prepend(WritePolicy policy,
                          WriteListener listener,
                          Key key,
                          Bin... bins)
                   throws AerospikeException
```
    Asynchronously prepend bin string values to existing record bin values. This method schedules the prepend command with a channel selector and returns. Another thread will process the command and send the results to the listener.
    The policy specifies the transaction timeout, record expiration and how the transaction is handled when the record already exists. This call works only for string values.
    
    Specified by:
    
    prepend in interface IAsyncClient
    
    Parameters:
    
    policy - write configuration parameters, pass in null for defaults
    
    listener - where to send results, pass in null for fire and forget
    
    key - unique record identifier
    
    bins - array of bin name/value pairs
    
    Throws:
    
    AerospikeException - if queue is full
  - add
```
public final void add(WritePolicy policy,
                      WriteListener listener,
                      Key key,
                      Bin... bins)
               throws AerospikeException
```
    Asynchronously add integer bin values to existing record bin values. This method schedules the add command with a channel selector and returns. Another thread will process the command and send the results to the listener.
    The policy specifies the transaction timeout, record expiration and how the transaction is handled when the record already exists. This call only works for integer values.
    
    Specified by:
    
    add in interface IAsyncClient
    
    Parameters:
    
    policy - write configuration parameters, pass in null for defaults
    
    listener - where to send results, pass in null for fire and forget
    
    key - unique record identifier
    
    bins - array of bin name/value pairs
    
    Throws:
    
    AerospikeException - if queue is full
  - delete
```
public final void delete(WritePolicy policy,
                         DeleteListener listener,
                         Key key)
                  throws AerospikeException
```
    Asynchronously delete record for specified key. This method schedules the delete command with a channel selector and returns. Another thread will process the command and send the results to the listener.
    The policy specifies the transaction timeout.
    
    Specified by:
    
    delete in interface IAsyncClient
    
    Parameters:
    
    policy - delete configuration parameters, pass in null for defaults
    
    listener - where to send results, pass in null for fire and forget
    
    key - unique record identifier
    
    Throws:
    
    AerospikeException - if queue is full
  - touch
```
public final void touch(WritePolicy policy,
                        WriteListener listener,
                        Key key)
                 throws AerospikeException
```
    Asynchronously create record if it does not already exist. If the record exists, the record's time to expiration will be reset to the policy's expiration.
    This method schedules the touch command with a channel selector and returns. Another thread will process the command and send the results to the listener.
    
    Specified by:
    
    touch in interface IAsyncClient
    
    Parameters:
    
    policy - write configuration parameters, pass in null for defaults
    
    listener - where to send results, pass in null for fire and forget
    
    key - unique record identifier
    
    Throws:
    
    AerospikeException - if queue is full
  - exists
```
public final void exists(Policy policy,
                         ExistsListener listener,
                         Key key)
                  throws AerospikeException
```
    Asynchronously determine if a record key exists. This method schedules the exists command with a channel selector and returns. Another thread will process the command and send the results to the listener.
    The policy can be used to specify timeouts.
    
    Specified by:
    
    exists in interface IAsyncClient
    
    Parameters:
    
    policy - generic configuration parameters, pass in null for defaults
    
    listener - where to send results
    
    key - unique record identifier
    
    Throws:
    
    AerospikeException - if queue is full
  - exists
```
public final void exists(BatchPolicy policy,
                         ExistsArrayListener listener,
                         Key[] keys)
                  throws AerospikeException
```
    Asynchronously check if multiple record keys exist in one batch call. This method schedules the exists command with a channel selector and returns. Another thread will process the command and send the results to the listener in a single call.
    The policy can be used to specify timeouts and maximum parallel commands.
    
    Specified by:
    
    exists in interface IAsyncClient
    
    Parameters:
    
    policy - batch configuration parameters, pass in null for defaults
    
    listener - where to send results
    
    keys - array of unique record identifiers
    
    Throws:
    
    AerospikeException - if queue is full
  - exists
```
public final void exists(BatchPolicy policy,
                         ExistsSequenceListener listener,
                         Key[] keys)
                  throws AerospikeException
```
    Asynchronously check if multiple record keys exist in one batch call. This method schedules the exists command with a channel selector and returns. Another thread will process the command and send the results to the listener in multiple unordered calls.
    The policy can be used to specify timeouts and maximum parallel commands.
    
    Specified by:
    
    exists in interface IAsyncClient
    
    Parameters:
    
    policy - batch configuration parameters, pass in null for defaults
    
    listener - where to send results
    
    keys - array of unique record identifiers
    
    Throws:
    
    AerospikeException - if queue is full
  - get
```
public final void get(Policy policy,
                      RecordListener listener,
                      Key key)
               throws AerospikeException
```
    Asynchronously read entire record for specified key. This method schedules the get command with a channel selector and returns. Another thread will process the command and send the results to the listener.
    The policy can be used to specify timeouts.
    
    Specified by:
    
    get in interface IAsyncClient
    
    Parameters:
    
    policy - generic configuration parameters, pass in null for defaults
    
    listener - where to send results
    
    key - unique record identifier
    
    Throws:
    
    AerospikeException - if queue is full
  - get
```
public final void get(Policy policy,
                      RecordListener listener,
                      Key key,
                      String... binNames)
               throws AerospikeException
```
    Asynchronously read record header and bins for specified key. This method schedules the get command with a channel selector and returns. Another thread will process the command and send the results to the listener.
    The policy can be used to specify timeouts.
    
    Specified by:
    
    get in interface IAsyncClient
    
    Parameters:
    
    policy - generic configuration parameters, pass in null for defaults
    
    listener - where to send results
    
    key - unique record identifier
    
    binNames - bins to retrieve
    
    Throws:
    
    AerospikeException - if queue is full
  - getHeader
```
public final void getHeader(Policy policy,
                            RecordListener listener,
                            Key key)
                     throws AerospikeException
```
    Asynchronously read record generation and expiration only for specified key. Bins are not read. This method schedules the get command with a channel selector and returns. Another thread will process the command and send the results to the listener.
    The policy can be used to specify timeouts.
    
    Specified by:
    
    getHeader in interface IAsyncClient
    
    Parameters:
    
    policy - generic configuration parameters, pass in null for defaults
    
    listener - where to send results
    
    key - unique record identifier
    
    Throws:
    
    AerospikeException - if queue is full
  - get
```
public final void get(BatchPolicy policy,
                      BatchListListener listener,
                      List<BatchRead> records)
               throws AerospikeException
```
    Asynchronously read multiple records for specified batch keys in one batch call. This method allows different namespaces/bins to be requested for each key in the batch. The returned records are located in the same list. If the BatchRead key field is not found, the corresponding record field will be null.
    This method schedules the get command with a channel selector and returns. Another thread will process the command and send the results to the listener in a single call. This method requires Aerospike Server version >= 3.6.0.
    
    Specified by:
    
    get in interface IAsyncClient
    
    Parameters:
    
    policy - batch configuration parameters, pass in null for defaults
    
    listener - where to send results
    
    records - list of unique record identifiers and the bins to retrieve.
    
    Throws:
    
    AerospikeException - if read fails
  - get
```
public final void get(BatchPolicy policy,
                      BatchSequenceListener listener,
                      List<BatchRead> records)
               throws AerospikeException
```
    Asynchronously read multiple records for specified batch keys in one batch call. This method allows different namespaces/bins to be requested for each key in the batch. The returned records are located in the same list. If the BatchRead key field is not found, the corresponding record field will be null.
    This method schedules the get command with a channel selector and returns. Another thread will process the command and send the results to the listener in a single call. This method requires Aerospike Server version >= 3.6.0.
    
    Specified by:
    
    get in interface IAsyncClient
    
    Parameters:
    
    policy - batch configuration parameters, pass in null for defaults
    
    listener - where to send results
    
    records - list of unique record identifiers and the bins to retrieve.
    
    Throws:
    
    AerospikeException - if read fails
  - get
```
public final void get(BatchPolicy policy,
                      RecordArrayListener listener,
                      Key[] keys)
               throws AerospikeException
```
    Asynchronously read multiple records for specified keys in one batch call. This method schedules the get command with a channel selector and returns. Another thread will process the command and send the results to the listener in a single call.
    If a key is not found, the record will be null. The policy can be used to specify timeouts and maximum parallel commands.
    
    Specified by:
    
    get in interface IAsyncClient
    
    Parameters:
    
    policy - batch configuration parameters, pass in null for defaults
    
    listener - where to send results
    
    keys - array of unique record identifiers
    
    Throws:
    
    AerospikeException - if queue is full
  - get
```
public final void get(BatchPolicy policy,
                      RecordSequenceListener listener,
                      Key[] keys)
               throws AerospikeException
```
    Asynchronously read multiple records for specified keys in one batch call. This method schedules the get command with a channel selector and returns. Another thread will process the command and send the results to the listener in multiple unordered calls.
    If a key is not found, the record will be null. The policy can be used to specify timeouts and maximum parallel commands.
    
    Specified by:
    
    get in interface IAsyncClient
    
    Parameters:
    
    policy - batch configuration parameters, pass in null for defaults
    
    listener - where to send results
    
    keys - array of unique record identifiers
    
    Throws:
    
    AerospikeException - if queue is full
  - get
```
public final void get(BatchPolicy policy,
                      RecordArrayListener listener,
                      Key[] keys,
                      String... binNames)
               throws AerospikeException
```
    Asynchronously read multiple record headers and bins for specified keys in one batch call. This method schedules the get command with a channel selector and returns. Another thread will process the command and send the results to the listener in a single call.
    If a key is not found, the record will be null. The policy can be used to specify timeouts and maximum parallel commands.
    
    Specified by:
    
    get in interface IAsyncClient
    
    Parameters:
    
    policy - batch configuration parameters, pass in null for defaults
    
    listener - where to send results
    
    keys - array of unique record identifiers
    
    binNames - array of bins to retrieve
    
    Throws:
    
    AerospikeException - if queue is full
  - get
```
public final void get(BatchPolicy policy,
                      RecordSequenceListener listener,
                      Key[] keys,
                      String... binNames)
               throws AerospikeException
```
    Asynchronously read multiple record headers and bins for specified keys in one batch call. This method schedules the get command with a channel selector and returns. Another thread will process the command and send the results to the listener in multiple unordered calls.
    If a key is not found, the record will be null. The policy can be used to specify timeouts and maximum parallel commands.
    
    Specified by:
    
    get in interface IAsyncClient
    
    Parameters:
    
    policy - batch configuration parameters, pass in null for defaults
    
    listener - where to send results
    
    keys - array of unique record identifiers
    
    binNames - array of bins to retrieve
    
    Throws:
    
    AerospikeException - if queue is full
  - getHeader
```
public final void getHeader(BatchPolicy policy,
                            RecordArrayListener listener,
                            Key[] keys)
                     throws AerospikeException
```
    Asynchronously read multiple record header data for specified keys in one batch call. This method schedules the get command with a channel selector and returns. Another thread will process the command and send the results to the listener in a single call.
    If a key is not found, the record will be null. The policy can be used to specify timeouts and maximum parallel commands.
    
    Specified by:
    
    getHeader in interface IAsyncClient
    
    Parameters:
    
    policy - batch configuration parameters, pass in null for defaults
    
    listener - where to send results
    
    keys - array of unique record identifiers
    
    Throws:
    
    AerospikeException - if queue is full
  - getHeader
```
public final void getHeader(BatchPolicy policy,
                            RecordSequenceListener listener,
                            Key[] keys)
                     throws AerospikeException
```
    Asynchronously read multiple record header data for specified keys in one batch call. This method schedules the get command with a channel selector and returns. Another thread will process the command and send the results to the listener in multiple unordered calls.
    If a key is not found, the record will be null. The policy can be used to specify timeouts and maximum parallel commands.
    
    Specified by:
    
    getHeader in interface IAsyncClient
    
    Parameters:
    
    policy - batch configuration parameters, pass in null for defaults
    
    listener - where to send results
    
    keys - array of unique record identifiers
    
    Throws:
    
    AerospikeException - if queue is full
  - operate
```
public final void operate(WritePolicy policy,
                          RecordListener listener,
                          Key key,
                          Operation... operations)
                   throws AerospikeException
```
    Asynchronously perform multiple read/write operations on a single key in one batch call. An example would be to add an integer value to an existing record and then read the result, all in one database call.
    This method schedules the operate command with a channel selector and returns. Another thread will process the command and send the results to the listener.
    Both scalar bin operations (Operation) and list bin operations (ListOperation) can be performed in same call.
    
    Specified by:
    
    operate in interface IAsyncClient
    
    Parameters:
    
    policy - write configuration parameters, pass in null for defaults
    
    listener - where to send results, pass in null for fire and forget
    
    key - unique record identifier
    
    operations - database operations to perform
    
    Throws:
    
    AerospikeException - if queue is full
  - scanAll
```
public final void scanAll(ScanPolicy policy,
                          RecordSequenceListener listener,
                          String namespace,
                          String setName,
                          String... binNames)
                   throws AerospikeException
```
    Asynchronously read all records in specified namespace and set. If the policy's concurrentNodes is specified, each server node will be read in parallel. Otherwise, server nodes are read in series.
    This method schedules the scan command with a channel selector and returns. Another thread will process the command and send the results to the listener.
    
    Specified by:
    
    scanAll in interface IAsyncClient
    
    Parameters:
    
    policy - scan configuration parameters, pass in null for defaults
    
    listener - where to send results
    
    namespace - namespace - equivalent to database name
    
    setName - optional set name - equivalent to database table
    
    binNames - optional bin to retrieve. All bins will be returned if not specified. Aerospike 2 servers ignore this parameter.
    
    Throws:
    
    AerospikeException - if queue is full
  - execute
```
public final void execute(WritePolicy policy,
                          ExecuteListener listener,
                          Key key,
                          String packageName,
                          String functionName,
                          Value... functionArgs)
                   throws AerospikeException
```
    Asynchronously execute user defined function on server and return results. The function operates on a single record. The package name is used to locate the udf file location on the server:
    udf file = /.lua
    This method schedules the execute command with a channel selector and returns. Another thread will process the command and send the results to the listener.
    
    Specified by:
    
    execute in interface IAsyncClient
    
    Parameters:
    
    policy - write configuration parameters, pass in null for defaults
    
    listener - where to send results, pass in null for fire and forget
    
    key - unique record identifier
    
    packageName - server package name where user defined function resides
    
    functionName - user defined function
    
    functionArgs - arguments passed in to user defined function
    
    Throws:
    
    AerospikeException - if transaction fails
  - query
```
public final void query(QueryPolicy policy,
                        RecordSequenceListener listener,
                        Statement statement)
                 throws AerospikeException
```
    Asynchronously execute query on all server nodes. The query policy's maxConcurrentNodes dictate how many nodes can be queried in parallel. The default is to query all nodes in parallel.
    This method schedules the node's query commands with channel selectors and returns. Selector threads will process the commands and send the results to the listener.
    
    Specified by:
    
    query in interface IAsyncClient
    
    Parameters:
    
    policy - query configuration parameters, pass in null for defaults
    
    listener - where to send results
    
    statement - database query command parameters
    
    Throws:
    
    AerospikeException - if query fails

Class AsyncClient

Field Summary

Fields inherited from class com.aerospike.client.AerospikeClient

Constructor Summary

Method Summary

Methods inherited from class com.aerospike.client.AerospikeClient

Methods inherited from class java.lang.Object

Methods inherited from interface com.aerospike.client.IAerospikeClient

Field Detail

asyncReadPolicyDefault

asyncWritePolicyDefault

asyncScanPolicyDefault

asyncQueryPolicyDefault

asyncBatchPolicyDefault

Constructor Detail

AsyncClient

AsyncClient

AsyncClient

Method Detail

close

getAsyncReadPolicyDefault

getAsyncWritePolicyDefault

getAsyncScanPolicyDefault

getAsyncQueryPolicyDefault

getAsyncBatchPolicyDefault

put

append

prepend

add

delete

touch

exists

exists

exists

get

get

getHeader

get

get

get

get

get

get

getHeader

getHeader

operate

scanAll

execute

query