Modifier and Type | Class and Description |
---|---|
static class |
AerospikeException.AsyncQueueFull
Exception thrown when async command was rejected because the
async delay queue is full.
|
static class |
AerospikeException.Connection
Exception thrown when client can't connect to the server.
|
static class |
AerospikeException.InvalidNode
Exception thrown when chosen node is not active.
|
static class |
AerospikeException.Parse
Exception thrown when client can't parse data returned from server.
|
static class |
AerospikeException.QueryTerminated
Exception thrown when query was terminated prematurely.
|
static class |
AerospikeException.ScanTerminated
Exception thrown when scan was terminated prematurely.
|
static class |
AerospikeException.Serialize
Exception thrown when Java serialization error occurs.
|
static class |
AerospikeException.Timeout
Exception thrown when database request expires before completing.
|
Modifier and Type | Method and Description |
---|---|
void |
AerospikeClient.add(EventLoop eventLoop,
WriteListener listener,
WritePolicy policy,
Key key,
Bin... bins)
Asynchronously add integer bin values to existing record bin values.
|
void |
IAerospikeClient.add(EventLoop eventLoop,
WriteListener listener,
WritePolicy policy,
Key key,
Bin... bins)
Asynchronously add integer bin values to existing record bin values.
|
void |
AerospikeClient.add(WritePolicy policy,
Key key,
Bin... bins)
Add integer bin values to existing record bin values.
|
void |
IAerospikeClient.add(WritePolicy policy,
Key key,
Bin... bins)
Add integer bin values to existing record bin values.
|
void |
AerospikeClient.append(EventLoop eventLoop,
WriteListener listener,
WritePolicy policy,
Key key,
Bin... bins)
Asynchronously append bin string values to existing record bin values.
|
void |
IAerospikeClient.append(EventLoop eventLoop,
WriteListener listener,
WritePolicy policy,
Key key,
Bin... bins)
Asynchronously append bin string values to existing record bin values.
|
void |
AerospikeClient.append(WritePolicy policy,
Key key,
Bin... bins)
Append bin string values to existing record bin values.
|
void |
IAerospikeClient.append(WritePolicy policy,
Key key,
Bin... bins)
Append bin string values to existing record bin values.
|
void |
AerospikeClient.changePassword(AdminPolicy policy,
String user,
String password)
Change user's password.
|
void |
IAerospikeClient.changePassword(AdminPolicy policy,
String user,
String password)
Change user's password.
|
static byte[] |
Key.computeDigest(String setName,
Value key)
Generate unique server hash value from set name, key type and user defined key.
|
IndexTask |
AerospikeClient.createIndex(Policy policy,
String namespace,
String setName,
String indexName,
String binName,
IndexType indexType)
Create scalar secondary index.
|
IndexTask |
IAerospikeClient.createIndex(Policy policy,
String namespace,
String setName,
String indexName,
String binName,
IndexType indexType)
Create scalar secondary index.
|
IndexTask |
AerospikeClient.createIndex(Policy policy,
String namespace,
String setName,
String indexName,
String binName,
IndexType indexType,
IndexCollectionType indexCollectionType)
Create complex secondary index to be used on bins containing collections.
|
IndexTask |
IAerospikeClient.createIndex(Policy policy,
String namespace,
String setName,
String indexName,
String binName,
IndexType indexType,
IndexCollectionType indexCollectionType)
Create complex secondary index to be used on bins containing collections.
|
void |
AerospikeClient.createRole(AdminPolicy policy,
String roleName,
List<Privilege> privileges)
Create user defined role.
|
void |
IAerospikeClient.createRole(AdminPolicy policy,
String roleName,
List<Privilege> privileges)
Create user defined role.
|
void |
AerospikeClient.createUser(AdminPolicy policy,
String user,
String password,
List<String> roles)
Create user with password and roles.
|
void |
IAerospikeClient.createUser(AdminPolicy policy,
String user,
String password,
List<String> roles)
Create user with password and roles.
|
void |
AerospikeClient.delete(EventLoop eventLoop,
DeleteListener listener,
WritePolicy policy,
Key key)
Asynchronously delete record for specified key.
|
void |
IAerospikeClient.delete(EventLoop eventLoop,
DeleteListener listener,
WritePolicy policy,
Key key)
Asynchronously delete record for specified key.
|
boolean |
AerospikeClient.delete(WritePolicy policy,
Key key)
Delete record for specified key.
|
boolean |
IAerospikeClient.delete(WritePolicy policy,
Key key)
Delete record for specified key.
|
IndexTask |
AerospikeClient.dropIndex(Policy policy,
String namespace,
String setName,
String indexName)
Delete secondary index.
|
IndexTask |
IAerospikeClient.dropIndex(Policy policy,
String namespace,
String setName,
String indexName)
Delete secondary index.
|
void |
AerospikeClient.dropRole(AdminPolicy policy,
String roleName)
Drop user defined role.
|
void |
IAerospikeClient.dropRole(AdminPolicy policy,
String roleName)
Drop user defined role.
|
void |
AerospikeClient.dropUser(AdminPolicy policy,
String user)
Remove user from cluster.
|
void |
IAerospikeClient.dropUser(AdminPolicy policy,
String user)
Remove user from cluster.
|
abstract int |
Value.estimateSize()
Calculate number of bytes necessary to serialize the value in the wire protocol.
|
int |
Value.ValueArray.estimateSize() |
int |
Value.ListValue.estimateSize() |
int |
Value.MapValue.estimateSize() |
void |
AerospikeClient.execute(EventLoop eventLoop,
ExecuteListener listener,
WritePolicy policy,
Key key,
String packageName,
String functionName,
Value... functionArgs)
Asynchronously execute user defined function on server.
|
void |
IAerospikeClient.execute(EventLoop eventLoop,
ExecuteListener listener,
WritePolicy policy,
Key key,
String packageName,
String functionName,
Value... functionArgs)
Asynchronously execute user defined function on server.
|
Object |
AerospikeClient.execute(WritePolicy policy,
Key key,
String packageName,
String functionName,
Value... functionArgs)
Execute user defined function on server and return results.
|
Object |
IAerospikeClient.execute(WritePolicy policy,
Key key,
String packageName,
String functionName,
Value... args)
Execute user defined function on server and return results.
|
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.
|
boolean[] |
AerospikeClient.exists(BatchPolicy policy,
Key[] keys)
Check if multiple record keys exist in one batch call.
|
boolean[] |
IAerospikeClient.exists(BatchPolicy policy,
Key[] keys)
Check if multiple record keys exist in one batch call.
|
void |
AerospikeClient.exists(EventLoop eventLoop,
ExistsArrayListener listener,
BatchPolicy policy,
Key[] keys)
Asynchronously check if multiple record keys exist in one batch call.
|
void |
IAerospikeClient.exists(EventLoop eventLoop,
ExistsArrayListener listener,
BatchPolicy policy,
Key[] keys)
Asynchronously check if multiple record keys exist in one batch call.
|
void |
AerospikeClient.exists(EventLoop eventLoop,
ExistsListener listener,
Policy policy,
Key key)
Asynchronously determine if a record key exists.
|
void |
IAerospikeClient.exists(EventLoop eventLoop,
ExistsListener listener,
Policy policy,
Key key)
Asynchronously determine if a record key exists.
|
void |
AerospikeClient.exists(EventLoop eventLoop,
ExistsSequenceListener listener,
BatchPolicy policy,
Key[] keys)
Asynchronously check if multiple record keys exist in one batch call.
|
void |
IAerospikeClient.exists(EventLoop eventLoop,
ExistsSequenceListener listener,
BatchPolicy policy,
Key[] keys)
Asynchronously check if multiple record keys exist in one batch call.
|
boolean |
AerospikeClient.exists(Policy policy,
Key key)
Determine if a record key exists.
|
boolean |
IAerospikeClient.exists(Policy policy,
Key key)
Determine if a record key exists.
|
Record[] |
AerospikeClient.get(BatchPolicy policy,
Key[] keys)
Read multiple records for specified keys in one batch call.
|
Record[] |
IAerospikeClient.get(BatchPolicy policy,
Key[] keys)
Read multiple records for specified keys in one batch call.
|
Record[] |
AerospikeClient.get(BatchPolicy policy,
Key[] keys,
String... binNames)
Read multiple record headers and bins for specified keys in one batch call.
|
Record[] |
IAerospikeClient.get(BatchPolicy policy,
Key[] keys,
String... binNames)
Read multiple record headers and bins for specified keys in one batch call.
|
void |
AerospikeClient.get(BatchPolicy policy,
List<BatchRead> records)
Read multiple records for specified batch keys in one batch call.
|
void |
IAerospikeClient.get(BatchPolicy policy,
List<BatchRead> records)
Read multiple records for specified batch keys in one batch call.
|
void |
AerospikeClient.get(EventLoop eventLoop,
BatchListListener listener,
BatchPolicy policy,
List<BatchRead> records)
Asynchronously read multiple records for specified batch keys in one batch call.
|
void |
IAerospikeClient.get(EventLoop eventLoop,
BatchListListener listener,
BatchPolicy policy,
List<BatchRead> records)
Asynchronously read multiple records for specified batch keys in one batch call.
|
void |
AerospikeClient.get(EventLoop eventLoop,
BatchSequenceListener listener,
BatchPolicy policy,
List<BatchRead> records)
Asynchronously read multiple records for specified batch keys in one batch call.
|
void |
IAerospikeClient.get(EventLoop eventLoop,
BatchSequenceListener listener,
BatchPolicy policy,
List<BatchRead> records)
Asynchronously read multiple records for specified batch keys in one batch call.
|
void |
AerospikeClient.get(EventLoop eventLoop,
RecordArrayListener listener,
BatchPolicy policy,
Key[] keys)
Asynchronously read multiple records for specified keys in one batch call.
|
void |
IAerospikeClient.get(EventLoop eventLoop,
RecordArrayListener listener,
BatchPolicy policy,
Key[] keys)
Asynchronously read multiple records for specified keys in one batch call.
|
void |
AerospikeClient.get(EventLoop eventLoop,
RecordArrayListener listener,
BatchPolicy policy,
Key[] keys,
String... binNames)
Asynchronously read multiple record headers and bins for specified keys in one batch call.
|
void |
IAerospikeClient.get(EventLoop eventLoop,
RecordArrayListener listener,
BatchPolicy policy,
Key[] keys,
String... binNames)
Asynchronously read multiple record headers and bins for specified keys in one batch call.
|
void |
AerospikeClient.get(EventLoop eventLoop,
RecordListener listener,
Policy policy,
Key key)
Asynchronously read entire record for specified key.
|
void |
IAerospikeClient.get(EventLoop eventLoop,
RecordListener listener,
Policy policy,
Key key)
Asynchronously read entire record for specified key.
|
void |
AerospikeClient.get(EventLoop eventLoop,
RecordListener listener,
Policy policy,
Key key,
String... binNames)
Asynchronously read record header and bins for specified key.
|
void |
IAerospikeClient.get(EventLoop eventLoop,
RecordListener listener,
Policy policy,
Key key,
String... binNames)
Asynchronously read record header and bins for specified key.
|
void |
AerospikeClient.get(EventLoop eventLoop,
RecordSequenceListener listener,
BatchPolicy policy,
Key[] keys)
Asynchronously read multiple records for specified keys in one batch call.
|
void |
IAerospikeClient.get(EventLoop eventLoop,
RecordSequenceListener listener,
BatchPolicy policy,
Key[] keys)
Asynchronously read multiple records for specified keys in one batch call.
|
void |
AerospikeClient.get(EventLoop eventLoop,
RecordSequenceListener listener,
BatchPolicy policy,
Key[] keys,
String... binNames)
Asynchronously read multiple record headers and bins for specified keys in one batch call.
|
void |
IAerospikeClient.get(EventLoop eventLoop,
RecordSequenceListener listener,
BatchPolicy policy,
Key[] keys,
String... binNames)
Asynchronously read multiple record headers and bins for specified keys in one batch call.
|
Record |
AerospikeClient.get(Policy policy,
Key key)
Read entire record for specified key.
|
Record |
IAerospikeClient.get(Policy policy,
Key key)
Read entire record for specified key.
|
Record |
AerospikeClient.get(Policy policy,
Key key,
String... binNames)
Read record header and bins for specified key.
|
Record |
IAerospikeClient.get(Policy policy,
Key key,
String... binNames)
Read record header and bins for specified key.
|
Record[] |
AerospikeClient.getHeader(BatchPolicy policy,
Key[] keys)
Read multiple record header data for specified keys in one batch call.
|
Record[] |
IAerospikeClient.getHeader(BatchPolicy policy,
Key[] keys)
Read multiple record header data for specified keys in one batch call.
|
void |
AerospikeClient.getHeader(EventLoop eventLoop,
RecordArrayListener listener,
BatchPolicy policy,
Key[] keys)
Asynchronously read multiple record header data for specified keys in one batch call.
|
void |
IAerospikeClient.getHeader(EventLoop eventLoop,
RecordArrayListener listener,
BatchPolicy policy,
Key[] keys)
Asynchronously read multiple record header data for specified keys in one batch call.
|
void |
AerospikeClient.getHeader(EventLoop eventLoop,
RecordListener listener,
Policy policy,
Key key)
Asynchronously read record generation and expiration only for specified key.
|
void |
IAerospikeClient.getHeader(EventLoop eventLoop,
RecordListener listener,
Policy policy,
Key key)
Asynchronously read record generation and expiration only for specified key.
|
void |
AerospikeClient.getHeader(EventLoop eventLoop,
RecordSequenceListener listener,
BatchPolicy policy,
Key[] keys)
Asynchronously read multiple record header data for specified keys in one batch call.
|
void |
IAerospikeClient.getHeader(EventLoop eventLoop,
RecordSequenceListener listener,
BatchPolicy policy,
Key[] keys)
Asynchronously read multiple record header data for specified keys in one batch call.
|
Record |
AerospikeClient.getHeader(Policy policy,
Key key)
Read record generation and expiration only for specified key.
|
Record |
IAerospikeClient.getHeader(Policy policy,
Key key)
Read record generation and expiration only for specified key.
|
void |
AerospikeClient.grantPrivileges(AdminPolicy policy,
String roleName,
List<Privilege> privileges)
Grant privileges to an user defined role.
|
void |
IAerospikeClient.grantPrivileges(AdminPolicy policy,
String roleName,
List<Privilege> privileges)
Grant privileges to an user defined role.
|
void |
AerospikeClient.grantRoles(AdminPolicy policy,
String user,
List<String> roles)
Add roles to user's list of roles.
|
void |
IAerospikeClient.grantRoles(AdminPolicy policy,
String user,
List<String> roles)
Add roles to user's list of roles.
|
void |
AerospikeClient.operate(EventLoop eventLoop,
RecordListener listener,
WritePolicy policy,
Key key,
Operation... operations)
Asynchronously perform multiple read/write operations on a single key in one batch call.
|
void |
IAerospikeClient.operate(EventLoop eventLoop,
RecordListener listener,
WritePolicy policy,
Key key,
Operation... operations)
Asynchronously perform multiple read/write operations on a single key in one batch call.
|
Record |
AerospikeClient.operate(WritePolicy policy,
Key key,
Operation... operations)
Perform multiple read/write operations on a single key in one batch call.
|
Record |
IAerospikeClient.operate(WritePolicy policy,
Key key,
Operation... operations)
Perform multiple read/write operations on a single key in one batch call.
|
HashMap<String,String> |
Info.parseMultiResponse() |
void |
AerospikeClient.prepend(EventLoop eventLoop,
WriteListener listener,
WritePolicy policy,
Key key,
Bin... bins)
Asynchronously prepend bin string values to existing record bin values.
|
void |
IAerospikeClient.prepend(EventLoop eventLoop,
WriteListener listener,
WritePolicy policy,
Key key,
Bin... bins)
Asynchronously prepend bin string values to existing record bin values.
|
void |
AerospikeClient.prepend(WritePolicy policy,
Key key,
Bin... bins)
Prepend bin string values to existing record bin values.
|
void |
IAerospikeClient.prepend(WritePolicy policy,
Key key,
Bin... bins)
Prepend bin string values to existing record bin values.
|
void |
AerospikeClient.put(EventLoop eventLoop,
WriteListener listener,
WritePolicy policy,
Key key,
Bin... bins)
Asynchronously write record bin(s).
|
void |
IAerospikeClient.put(EventLoop eventLoop,
WriteListener listener,
WritePolicy policy,
Key key,
Bin... bins)
Asynchronously write record bin(s).
|
void |
AerospikeClient.put(WritePolicy policy,
Key key,
Bin... bins)
Write record bin(s).
|
void |
IAerospikeClient.put(WritePolicy policy,
Key key,
Bin... bins)
Write record bin(s).
|
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.
|
Role |
AerospikeClient.queryRole(AdminPolicy policy,
String roleName)
Retrieve role definition.
|
Role |
IAerospikeClient.queryRole(AdminPolicy policy,
String roleName)
Retrieve role definition.
|
List<Role> |
AerospikeClient.queryRoles(AdminPolicy policy)
Retrieve all roles.
|
List<Role> |
IAerospikeClient.queryRoles(AdminPolicy policy)
Retrieve all roles.
|
User |
AerospikeClient.queryUser(AdminPolicy policy,
String user)
Retrieve roles for a given user.
|
User |
IAerospikeClient.queryUser(AdminPolicy policy,
String user)
Retrieve roles for a given user.
|
List<User> |
AerospikeClient.queryUsers(AdminPolicy policy)
Retrieve all users and their roles.
|
List<User> |
IAerospikeClient.queryUsers(AdminPolicy policy)
Retrieve all users and their roles.
|
RegisterTask |
AerospikeClient.register(Policy policy,
ClassLoader resourceLoader,
String resourcePath,
String serverPath,
Language language)
Register package located in a resource containing user defined functions with server.
|
RegisterTask |
IAerospikeClient.register(Policy policy,
ClassLoader resourceLoader,
String resourcePath,
String serverPath,
Language language)
Register package located in a resource containing user defined functions with server.
|
RegisterTask |
AerospikeClient.register(Policy policy,
String clientPath,
String serverPath,
Language language)
Register package located in a file containing user defined functions with server.
|
RegisterTask |
IAerospikeClient.register(Policy policy,
String clientPath,
String serverPath,
Language language)
Register package located in a file containing user defined functions with server.
|
RegisterTask |
AerospikeClient.registerUdfString(Policy policy,
String code,
String serverPath,
Language language)
Register UDF functions located in a code string with server.
|
RegisterTask |
IAerospikeClient.registerUdfString(Policy policy,
String code,
String serverPath,
Language language)
Register UDF functions located in a code string with server.
|
void |
AerospikeClient.removeUdf(InfoPolicy policy,
String serverPath)
Remove user defined function from server nodes.
|
void |
IAerospikeClient.removeUdf(InfoPolicy policy,
String serverPath)
Remove user defined function from server nodes.
|
static HashMap<String,String> |
Info.request(com.aerospike.client.cluster.Connection conn)
Get all the default info from the specified database server node.
|
static HashMap<String,String> |
Info.request(com.aerospike.client.cluster.Connection conn,
List<String> names)
Get many info values by name from the specified database server node.
|
static HashMap<String,String> |
Info.request(com.aerospike.client.cluster.Connection conn,
String... names)
Get many info values by name from the specified database server node.
|
static String |
Info.request(com.aerospike.client.cluster.Connection conn,
String name)
Get one info value by name from the specified database server node.
|
static HashMap<String,String> |
Info.request(InetSocketAddress socketAddress)
Get all the default info from the specified database server node.
|
static HashMap<String,String> |
Info.request(InetSocketAddress socketAddress,
String... names)
Get many info values by name from the specified database server node.
|
static String |
Info.request(InetSocketAddress socketAddress,
String name)
Get one info value by name from the specified database server node.
|
static Map<String,String> |
Info.request(InfoPolicy policy,
Node node)
Get default info values from the specified database server node.
|
static Map<String,String> |
Info.request(InfoPolicy policy,
Node node,
String... names)
Get many info values by name from the specified database server node.
|
static String |
Info.request(InfoPolicy policy,
Node node,
String name)
Get one info value by name from the specified database server node.
|
static String |
Info.request(Node node,
String name)
Get one info value by name from the specified database server node.
|
static HashMap<String,String> |
Info.request(String hostname,
int port)
Get default info from the specified database server node, using host name and port.
|
static HashMap<String,String> |
Info.request(String hostname,
int port,
String... names)
Get many info values by name from the specified database server node,
using host name and port.
|
static String |
Info.request(String hostname,
int port,
String name)
Get one info value by name from the specified database server node, using
host name and port.
|
void |
AerospikeClient.revokePrivileges(AdminPolicy policy,
String roleName,
List<Privilege> privileges)
Revoke privileges from an user defined role.
|
void |
IAerospikeClient.revokePrivileges(AdminPolicy policy,
String roleName,
List<Privilege> privileges)
Revoke privileges from an user defined role.
|
void |
AerospikeClient.revokeRoles(AdminPolicy policy,
String user,
List<String> roles)
Remove roles from user's list of roles.
|
void |
IAerospikeClient.revokeRoles(AdminPolicy policy,
String user,
List<String> roles)
Remove roles from user's list of roles.
|
void |
AerospikeClient.scanAll(EventLoop eventLoop,
RecordSequenceListener listener,
ScanPolicy policy,
String namespace,
String setName,
String... binNames)
Asynchronously read all records in specified namespace and set.
|
void |
IAerospikeClient.scanAll(EventLoop eventLoop,
RecordSequenceListener listener,
ScanPolicy policy,
String namespace,
String setName,
String... binNames)
Asynchronously read all records in specified namespace and set.
|
void |
AerospikeClient.scanAll(ScanPolicy policy,
String namespace,
String setName,
ScanCallback callback,
String... binNames)
Read all records in specified namespace and set.
|
void |
IAerospikeClient.scanAll(ScanPolicy policy,
String namespace,
String setName,
ScanCallback callback,
String... binNames)
Read all records in specified namespace and set.
|
void |
ScanCallback.scanCallback(Key key,
Record record)
This method will be called for each record returned from a scan.
|
void |
AerospikeClient.scanNode(ScanPolicy policy,
Node node,
String namespace,
String setName,
ScanCallback callback,
String... binNames)
Read all records in specified namespace and set for one node only.
|
void |
IAerospikeClient.scanNode(ScanPolicy policy,
Node node,
String namespace,
String setName,
ScanCallback callback,
String... binNames)
Read all records in specified namespace and set for one node only.
|
void |
AerospikeClient.scanNode(ScanPolicy policy,
String nodeName,
String namespace,
String setName,
ScanCallback callback,
String... binNames)
Read all records in specified namespace and set for one node only.
|
void |
IAerospikeClient.scanNode(ScanPolicy policy,
String nodeName,
String namespace,
String setName,
ScanCallback callback,
String... binNames)
Read all records in specified namespace and set for one node only.
|
void |
AerospikeClient.touch(EventLoop eventLoop,
WriteListener listener,
WritePolicy policy,
Key key)
Asynchronously reset record's time to expiration using the policy's expiration.
|
void |
IAerospikeClient.touch(EventLoop eventLoop,
WriteListener listener,
WritePolicy policy,
Key key)
Asynchronously reset record's time to expiration using the policy's expiration.
|
void |
AerospikeClient.touch(WritePolicy policy,
Key key)
Reset record's time to expiration using the policy's expiration.
|
void |
IAerospikeClient.touch(WritePolicy policy,
Key key)
Reset record's time to expiration using the policy's expiration.
|
void |
AerospikeClient.truncate(InfoPolicy policy,
String ns,
String set,
Calendar beforeLastUpdate)
Remove records in specified namespace/set efficiently.
|
void |
IAerospikeClient.truncate(InfoPolicy policy,
String ns,
String set,
Calendar beforeLastUpdate)
Remove records in specified namespace/set efficiently.
|
void |
Value.validateKeyType()
Validate if value type can be used as a key.
|
abstract int |
Value.write(byte[] buffer,
int offset)
Serialize the value in the wire protocol.
|
Constructor and Description |
---|
AerospikeClient(ClientPolicy policy,
Host... hosts)
Initialize Aerospike client with suitable hosts to seed the cluster map.
|
AerospikeClient(ClientPolicy policy,
String hostname,
int port)
Initialize Aerospike client.
|
AerospikeClient(String hostname,
int port)
Initialize Aerospike client.
|
Info(com.aerospike.client.cluster.Connection conn)
Send default empty command to server and store results.
|
Info(com.aerospike.client.cluster.Connection conn,
List<String> commands)
Send multiple commands to server and store results.
|
Info(com.aerospike.client.cluster.Connection conn,
String... commands)
Send multiple commands to server and store results.
|
Info(com.aerospike.client.cluster.Connection conn,
String command)
Send single command to server and store results.
|
Key(String namespace,
String setName,
byte[] key)
Initialize key from namespace, optional set name and user key.
|
Key(String namespace,
String setName,
byte[] key,
int offset,
int length)
Initialize key from namespace, optional set name and user key.
|
Key(String namespace,
String setName,
int key)
Initialize key from namespace, optional set name and user key.
|
Key(String namespace,
String setName,
long key)
Initialize key from namespace, optional set name and user key.
|
Key(String namespace,
String setName,
String key)
Initialize key from namespace, optional set name and user key.
|
Key(String namespace,
String setName,
Value key)
Initialize key from namespace, optional set name and user key.
|
Modifier and Type | Method and Description |
---|---|
void |
AsyncClient.add(WritePolicy policy,
WriteListener listener,
Key key,
Bin... bins)
Asynchronously add integer bin values to existing record bin values.
|
void |
IAsyncClient.add(WritePolicy policy,
WriteListener listener,
Key key,
Bin... bins)
Asynchronously add integer bin values to existing record bin values.
|
void |
AsyncClient.append(WritePolicy policy,
WriteListener listener,
Key key,
Bin... bins)
Asynchronously append bin string values to existing record bin values.
|
void |
IAsyncClient.append(WritePolicy policy,
WriteListener listener,
Key key,
Bin... bins)
Asynchronously append bin string values to existing record bin values.
|
void |
AsyncClient.delete(WritePolicy policy,
DeleteListener listener,
Key key)
Asynchronously delete record for specified key.
|
void |
IAsyncClient.delete(WritePolicy policy,
DeleteListener listener,
Key key)
Asynchronously delete record for specified key.
|
void |
AsyncClient.execute(WritePolicy policy,
ExecuteListener listener,
Key key,
String packageName,
String functionName,
Value... functionArgs)
Asynchronously execute user defined function on server and return results.
|
void |
IAsyncClient.execute(WritePolicy policy,
ExecuteListener listener,
Key key,
String packageName,
String functionName,
Value... functionArgs)
Asynchronously execute user defined function on server and return results.
|
void |
AsyncClient.exists(BatchPolicy policy,
ExistsArrayListener listener,
Key[] keys)
Asynchronously check if multiple record keys exist in one batch call.
|
void |
IAsyncClient.exists(BatchPolicy policy,
ExistsArrayListener listener,
Key[] keys)
Asynchronously check if multiple record keys exist in one batch call.
|
void |
AsyncClient.exists(BatchPolicy policy,
ExistsSequenceListener listener,
Key[] keys)
Asynchronously check if multiple record keys exist in one batch call.
|
void |
IAsyncClient.exists(BatchPolicy policy,
ExistsSequenceListener listener,
Key[] keys)
Asynchronously check if multiple record keys exist in one batch call.
|
void |
AsyncClient.exists(Policy policy,
ExistsListener listener,
Key key)
Asynchronously determine if a record key exists.
|
void |
IAsyncClient.exists(Policy policy,
ExistsListener listener,
Key key)
Asynchronously determine if a record key exists.
|
void |
AsyncClient.get(BatchPolicy policy,
BatchListListener listener,
List<BatchRead> records)
Asynchronously read multiple records for specified batch keys in one batch call.
|
void |
IAsyncClient.get(BatchPolicy policy,
BatchListListener listener,
List<BatchRead> records)
Asynchronously read multiple records for specified batch keys in one batch call.
|
void |
AsyncClient.get(BatchPolicy policy,
BatchSequenceListener listener,
List<BatchRead> records)
Asynchronously read multiple records for specified batch keys in one batch call.
|
void |
IAsyncClient.get(BatchPolicy policy,
BatchSequenceListener listener,
List<BatchRead> records)
Asynchronously read multiple records for specified batch keys in one batch call.
|
void |
AsyncClient.get(BatchPolicy policy,
RecordArrayListener listener,
Key[] keys)
Asynchronously read multiple records for specified keys in one batch call.
|
void |
IAsyncClient.get(BatchPolicy policy,
RecordArrayListener listener,
Key[] keys)
Asynchronously read multiple records for specified keys in one batch call.
|
void |
AsyncClient.get(BatchPolicy policy,
RecordArrayListener listener,
Key[] keys,
String... binNames)
Asynchronously read multiple record headers and bins for specified keys in one batch call.
|
void |
IAsyncClient.get(BatchPolicy policy,
RecordArrayListener listener,
Key[] keys,
String... binNames)
Asynchronously read multiple record headers and bins for specified keys in one batch call.
|
void |
AsyncClient.get(BatchPolicy policy,
RecordSequenceListener listener,
Key[] keys)
Asynchronously read multiple records for specified keys in one batch call.
|
void |
IAsyncClient.get(BatchPolicy policy,
RecordSequenceListener listener,
Key[] keys)
Asynchronously read multiple records for specified keys in one batch call.
|
void |
AsyncClient.get(BatchPolicy policy,
RecordSequenceListener listener,
Key[] keys,
String... binNames)
Asynchronously read multiple record headers and bins for specified keys in one batch call.
|
void |
IAsyncClient.get(BatchPolicy policy,
RecordSequenceListener listener,
Key[] keys,
String... binNames)
Asynchronously read multiple record headers and bins for specified keys in one batch call.
|
void |
AsyncClient.get(Policy policy,
RecordListener listener,
Key key)
Asynchronously read entire record for specified key.
|
void |
IAsyncClient.get(Policy policy,
RecordListener listener,
Key key)
Asynchronously read entire record for specified key.
|
void |
AsyncClient.get(Policy policy,
RecordListener listener,
Key key,
String... binNames)
Asynchronously read record header and bins for specified key.
|
void |
IAsyncClient.get(Policy policy,
RecordListener listener,
Key key,
String... binNames)
Asynchronously read record header and bins for specified key.
|
void |
AsyncClient.getHeader(BatchPolicy policy,
RecordArrayListener listener,
Key[] keys)
Asynchronously read multiple record header data for specified keys in one batch call.
|
void |
IAsyncClient.getHeader(BatchPolicy policy,
RecordArrayListener listener,
Key[] keys)
Asynchronously read multiple record header data for specified keys in one batch call.
|
void |
AsyncClient.getHeader(BatchPolicy policy,
RecordSequenceListener listener,
Key[] keys)
Asynchronously read multiple record header data for specified keys in one batch call.
|
void |
IAsyncClient.getHeader(BatchPolicy policy,
RecordSequenceListener listener,
Key[] keys)
Asynchronously read multiple record header data for specified keys in one batch call.
|
void |
AsyncClient.getHeader(Policy policy,
RecordListener listener,
Key key)
Asynchronously read record generation and expiration only for specified key.
|
void |
IAsyncClient.getHeader(Policy policy,
RecordListener listener,
Key key)
Asynchronously read record generation and expiration only for specified key.
|
void |
AsyncClient.operate(WritePolicy policy,
RecordListener listener,
Key key,
Operation... operations)
Asynchronously perform multiple read/write operations on a single key in one batch call.
|
void |
IAsyncClient.operate(WritePolicy policy,
RecordListener listener,
Key key,
Operation... operations)
Asynchronously perform multiple read/write operations on a single key in one batch call.
|
void |
AsyncClient.prepend(WritePolicy policy,
WriteListener listener,
Key key,
Bin... bins)
Asynchronously prepend bin string values to existing record bin values.
|
void |
IAsyncClient.prepend(WritePolicy policy,
WriteListener listener,
Key key,
Bin... bins)
Asynchronously prepend bin string values to existing record bin values.
|
void |
AsyncClient.put(WritePolicy policy,
WriteListener listener,
Key key,
Bin... bins)
Asynchronously write record bin(s).
|
void |
IAsyncClient.put(WritePolicy policy,
WriteListener listener,
Key key,
Bin... bins)
Asynchronously write record bin(s).
|
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.
|
void |
AsyncClient.scanAll(ScanPolicy policy,
RecordSequenceListener listener,
String namespace,
String setName,
String... binNames)
Asynchronously read all records in specified namespace and set.
|
void |
IAsyncClient.scanAll(ScanPolicy policy,
RecordSequenceListener listener,
String namespace,
String setName,
String... binNames)
Asynchronously read all records in specified namespace and set.
|
void |
AsyncClient.touch(WritePolicy policy,
WriteListener listener,
Key key)
Asynchronously create record if it does not already exist.
|
void |
IAsyncClient.touch(WritePolicy policy,
WriteListener listener,
Key key)
Asynchronously create record if it does not already exist.
|
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.
|
NioEventLoops()
Create direct NIO event loops, one per CPU core.
|
NioEventLoops(EventPolicy policy,
int size)
Create direct NIO event loops.
|
NioEventLoops(int size)
Create direct NIO event loops.
|
Modifier and Type | Method and Description |
---|---|
com.aerospike.client.cluster.Connection |
Node.getConnection(int timeoutMillis)
Get a socket connection from connection pool to the server node.
|
Modifier and Type | Method and Description |
---|---|
void |
BatchListListener.onFailure(AerospikeException exception)
This method is called when an asynchronous batch get command fails.
|
void |
BatchSequenceListener.onFailure(AerospikeException exception)
This method is called when an asynchronous batch get command fails.
|
void |
DeleteListener.onFailure(AerospikeException exception)
This method is called when an asynchronous delete command fails.
|
void |
ExecuteListener.onFailure(AerospikeException exception)
This method is called when an asynchronous execute command fails.
|
void |
ExistsArrayListener.onFailure(AerospikeException exception)
This method is called when an asynchronous exists command fails.
|
void |
ExistsListener.onFailure(AerospikeException exception)
This method is called when an asynchronous exists command fails.
|
void |
ExistsSequenceListener.onFailure(AerospikeException exception)
This method is called when an asynchronous batch exists command fails.
|
void |
InfoListener.onFailure(AerospikeException ae)
This method is called when an asynchronous info command fails.
|
void |
RecordArrayListener.onFailure(AerospikeException exception)
This method is called when an asynchronous batch get command fails.
|
void |
RecordListener.onFailure(AerospikeException exception)
This method is called when an asynchronous get or operate command fails.
|
void |
RecordSequenceListener.onFailure(AerospikeException exception)
This method is called when an asynchronous batch get or scan command fails.
|
void |
WriteListener.onFailure(AerospikeException exception)
This method is called when an asynchronous write command fails.
|
Modifier and Type | Method and Description |
---|---|
void |
RecordSequenceListener.onRecord(Key key,
Record record)
This method is called when an asynchronous record is received from the server.
|
Modifier and Type | Method and Description |
---|---|
static com.aerospike.client.lua.LuaInstance |
LuaCache.getInstance()
Return lua instance from a pool.
|
static org.luaj.vm2.Prototype |
LuaCache.loadPackageFromFile(String packageName)
Load lua package from a file.
|
static org.luaj.vm2.Prototype |
LuaCache.loadPackageFromResource(ClassLoader resourceLoader,
String resourcePath,
String packageName)
Load lua package from a resource.
|
Modifier and Type | Method and Description |
---|---|
int |
Filter.estimateSize()
Estimate filter's byte send when sending command to server.
|
boolean |
RecordSet.next()
Retrieve next record.
|
boolean |
ResultSet.next()
Retrieve next result.
|
int |
Filter.write(byte[] buf,
int offset)
Write filter to send command buffer.
|
Modifier and Type | Method and Description |
---|---|
int |
ExecuteTask.queryStatus()
Query all nodes for task completion status.
|
int |
IndexTask.queryStatus()
Query all nodes for task completion status.
|
int |
RegisterTask.queryStatus()
Query all nodes for task completion status.
|
Copyright ? 2012–2018 Aerospike, Inc. All rights reserved.