|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use AerospikeException | |
---|---|
com.aerospike.client | |
com.aerospike.client.async | |
com.aerospike.client.large | |
com.aerospike.client.listener | |
com.aerospike.client.query |
Uses of AerospikeException in com.aerospike.client |
---|
Subclasses of AerospikeException in com.aerospike.client | |
---|---|
static class |
AerospikeException.CommandRejected
Exception thrown when asynchronous command was rejected because the max concurrent database commands have been exceeded. |
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. |
Methods in com.aerospike.client that throw AerospikeException | |
---|---|
void |
AerospikeClient.add(WritePolicy policy,
Key key,
Bin... bins)
Add integer bin values to existing record bin values. |
void |
AerospikeClient.append(WritePolicy policy,
Key key,
Bin... bins)
Append bin string values to existing record bin values. |
static byte[] |
Key.computeDigest(java.lang.String setName,
Value key)
Generate unique server hash value from set name, key type and user defined key. |
void |
AerospikeClient.createIndex(Policy policy,
java.lang.String namespace,
java.lang.String setName,
java.lang.String indexName,
java.lang.String binName,
IndexType indexType)
Create secondary index. |
boolean |
AerospikeClient.delete(WritePolicy policy,
Key key)
Delete record for specified key. |
void |
AerospikeClient.dropIndex(Policy policy,
java.lang.String namespace,
java.lang.String setName,
java.lang.String indexName)
Delete secondary index. |
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()
|
java.lang.Object |
AerospikeClient.execute(Policy policy,
Key key,
java.lang.String packageName,
java.lang.String functionName,
Value... args)
Execute user defined function on server and return results. |
void |
AerospikeClient.execute(Policy policy,
Statement statement,
java.lang.String packageName,
java.lang.String functionName,
Value... functionArgs)
Apply user defined function on records that match the statement filter. |
boolean |
AerospikeClient.exists(Policy policy,
Key key)
Determine if a record key exists. |
boolean[] |
AerospikeClient.exists(Policy policy,
Key[] keys)
Check if multiple record keys exist in one batch call. |
Record |
AerospikeClient.get(Policy policy,
Key key)
Read entire record for specified key. |
Record[] |
AerospikeClient.get(Policy policy,
Key[] keys)
Read multiple records for specified keys in one batch call. |
Record[] |
AerospikeClient.get(Policy policy,
Key[] keys,
java.lang.String... binNames)
Read multiple record headers and bins for specified keys in one batch call. |
Record |
AerospikeClient.get(Policy policy,
Key key,
java.lang.String... binNames)
Read record header and bins for specified key. |
Record |
AerospikeClient.getHeader(Policy policy,
Key key)
Read record generation and expiration only for specified key. |
Record[] |
AerospikeClient.getHeader(Policy policy,
Key[] keys)
Read multiple record header data for specified keys 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. |
void |
AerospikeClient.prepend(WritePolicy policy,
Key key,
Bin... bins)
Prepend bin string values to existing record bin values. |
void |
AerospikeClient.put(WritePolicy policy,
Key key,
Bin... bins)
Write record bin(s). |
RecordSet |
AerospikeClient.query(QueryPolicy policy,
Statement statement)
Execute query and return record iterator. |
ResultSet |
AerospikeClient.queryAggregate(QueryPolicy policy,
Statement statement,
java.lang.String packageName,
java.lang.String functionName,
Value... functionArgs)
Execute query, apply statement's aggregation function, and return result iterator. |
void |
AerospikeClient.register(Policy policy,
java.lang.String clientPath,
java.lang.String serverPath,
Language language)
Register package containing user defined functions with server. |
static java.util.HashMap<java.lang.String,java.lang.String> |
Info.request(com.aerospike.client.cluster.Connection conn)
Get all the default info from the specified database server node. |
static java.util.HashMap<java.lang.String,java.lang.String> |
Info.request(com.aerospike.client.cluster.Connection conn,
java.lang.String... names)
Get many info values by name from the specified database server node. |
static java.lang.String |
Info.request(com.aerospike.client.cluster.Connection conn,
java.lang.String name)
Get one info value by name from the specified database server node. |
static java.util.HashMap<java.lang.String,java.lang.String> |
Info.request(java.net.InetSocketAddress socketAddress)
Get all the default info from the specified database server node. |
static java.util.HashMap<java.lang.String,java.lang.String> |
Info.request(java.net.InetSocketAddress socketAddress,
java.lang.String... names)
Get many info values by name from the specified database server node. |
static java.lang.String |
Info.request(java.net.InetSocketAddress socketAddress,
java.lang.String name)
Get one info value by name from the specified database server node. |
static java.util.HashMap<java.lang.String,java.lang.String> |
Info.request(java.lang.String hostname,
int port)
Get default info from the specified database server node, using host name and port. |
static java.util.HashMap<java.lang.String,java.lang.String> |
Info.request(java.lang.String hostname,
int port,
java.lang.String... names)
Get many info values by name from the specified database server node, using host name and port. |
static java.lang.String |
Info.request(java.lang.String hostname,
int port,
java.lang.String name)
Get one info value by name from the specified database server node, using host name and port. |
void |
AerospikeClient.scanAll(ScanPolicy policy,
java.lang.String namespace,
java.lang.String setName,
ScanCallback callback,
java.lang.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,
java.lang.String namespace,
java.lang.String setName,
ScanCallback callback,
java.lang.String... binNames)
Read all records in specified namespace and set for one node only. |
void |
AerospikeClient.scanNode(ScanPolicy policy,
java.lang.String nodeName,
java.lang.String namespace,
java.lang.String setName,
ScanCallback callback,
java.lang.String... binNames)
Read all records in specified namespace and set for one node only. |
void |
AerospikeClient.touch(WritePolicy policy,
Key key)
Create record if it does not already exist. |
abstract int |
Value.write(byte[] buffer,
int offset)
Serialize the value in the wire protocol. |
Constructors in com.aerospike.client that throw AerospikeException | |
---|---|
AerospikeClient(ClientPolicy policy,
Host... hosts)
Initialize Aerospike client with suitable hosts to seed the cluster map. |
|
AerospikeClient(ClientPolicy policy,
java.lang.String hostname,
int port)
Initialize Aerospike client. |
|
AerospikeClient(java.lang.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,
java.lang.String... commands)
Send multiple commands to server and store results. |
|
Info(com.aerospike.client.cluster.Connection conn,
java.lang.String command)
Send single command to server and store results. |
|
Key(java.lang.String namespace,
java.lang.String setName,
byte[] key)
Initialize key from namespace, optional set name and user key. |
|
Key(java.lang.String namespace,
java.lang.String setName,
int key)
Initialize key from namespace, optional set name and user key. |
|
Key(java.lang.String namespace,
java.lang.String setName,
long key)
Initialize key from namespace, optional set name and user key. |
|
Key(java.lang.String namespace,
java.lang.String setName,
java.lang.String key)
Initialize key from namespace, optional set name and user key. |
|
Key(java.lang.String namespace,
java.lang.String setName,
Value key)
Initialize key from namespace, optional set name and user key. |
Uses of AerospikeException in com.aerospike.client.async |
---|
Methods in com.aerospike.client.async that throw AerospikeException | |
---|---|
void |
AsyncClient.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 |
AsyncClient.delete(WritePolicy policy,
DeleteListener listener,
Key key)
Asynchronously delete record for specified key. |
void |
AsyncClient.exists(Policy policy,
ExistsArrayListener 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 |
AsyncClient.exists(Policy policy,
ExistsSequenceListener listener,
Key[] keys)
Asynchronously check if multiple record keys exist in one batch call. |
void |
AsyncClient.get(Policy policy,
RecordArrayListener listener,
Key[] keys)
Asynchronously read multiple records for specified keys in one batch call. |
void |
AsyncClient.get(Policy policy,
RecordArrayListener listener,
Key[] keys,
java.lang.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 |
AsyncClient.get(Policy policy,
RecordListener listener,
Key key,
java.lang.String... binNames)
Asynchronously read record header and bins for specified key. |
void |
AsyncClient.get(Policy policy,
RecordSequenceListener listener,
Key[] keys)
Asynchronously read multiple records for specified keys in one batch call. |
void |
AsyncClient.get(Policy policy,
RecordSequenceListener listener,
Key[] keys,
java.lang.String... binNames)
Asynchronously read multiple record headers and bins for specified keys in one batch call. |
void |
AsyncClient.getHeader(Policy policy,
RecordArrayListener 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 |
AsyncClient.getHeader(Policy policy,
RecordSequenceListener listener,
Key[] keys)
Asynchronously read multiple record header data for specified keys in one batch call. |
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 |
AsyncClient.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 |
AsyncClient.scanAll(ScanPolicy policy,
RecordSequenceListener listener,
java.lang.String namespace,
java.lang.String setName,
java.lang.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. |
Constructors in com.aerospike.client.async that throw AerospikeException | |
---|---|
AsyncClient(AsyncClientPolicy policy,
Host... hosts)
Initialize asynchronous client with suitable hosts to seed the cluster map. |
|
AsyncClient(AsyncClientPolicy policy,
java.lang.String hostname,
int port)
Initialize asynchronous client. |
|
AsyncClient(java.lang.String hostname,
int port)
Initialize asynchronous client. |
Uses of AerospikeException in com.aerospike.client.large |
---|
Methods in com.aerospike.client.large that throw AerospikeException | |
---|---|
void |
LargeList.add(Value... values)
Add values to the list. |
void |
LargeSet.add(Value... values)
Add values to the set. |
void |
LargeList.add(Value value)
Add a value to the list. |
void |
LargeSet.add(Value value)
Add a value to the set. |
void |
LargeList.destroy()
Delete bin containing the list. |
void |
LargeMap.destroy()
Delete bin containing the map. |
void |
LargeSet.destroy()
Delete bin containing the set. |
void |
LargeStack.destroy()
Delete bin containing the stack. |
boolean |
LargeSet.exists(Value value)
Check existence of value in the set. |
java.util.List<?> |
LargeStack.filter(int peekCount,
java.lang.String filterName,
Value... filterArgs)
Select items from top of stack. |
java.util.List<?> |
LargeList.filter(java.lang.String filterName,
Value... filterArgs)
Select values from list and apply specified Lua filter. |
java.util.Map<?,?> |
LargeMap.filter(java.lang.String filterName,
Value... filterArgs)
Select items from map. |
java.util.List<?> |
LargeSet.filter(java.lang.String filterName,
Value... filterArgs)
Select values from set and apply specified Lua filter. |
java.util.List<?> |
LargeList.find(Value value)
Select values from list. |
java.util.List<?> |
LargeList.findThenFilter(Value value,
java.lang.String filterName,
Value... filterArgs)
Select values from list and apply specified Lua filter. |
java.util.Map<?,?> |
LargeMap.get(Value name)
Get value from map given name key. |
java.lang.Object |
LargeSet.get(Value value)
Select value from set. |
int |
LargeList.getCapacity()
Return maximum number of entries in the list. |
int |
LargeMap.getCapacity()
Return maximum number of entries for the map. |
int |
LargeSet.getCapacity()
Return maximum number of entries in the set. |
int |
LargeStack.getCapacity()
Return maximum number of entries for the stack. |
java.util.Map<?,?> |
LargeList.getConfig()
Return map of list configuration parameters. |
java.util.Map<?,?> |
LargeMap.getConfig()
Return map configuration parameters. |
java.util.Map<?,?> |
LargeSet.getConfig()
Return map of set configuration parameters. |
java.util.Map<?,?> |
LargeStack.getConfig()
Return map of stack configuration parameters. |
java.util.List<?> |
LargeStack.peek(int peekCount)
Select items from top of stack. |
void |
LargeStack.push(Value... values)
Push values onto stack. |
void |
LargeStack.push(Value value)
Push value onto stack. |
void |
LargeMap.put(java.util.Map<?,?> map)
Add map values to map. |
void |
LargeMap.put(Value name,
Value value)
Add entry to map. |
void |
LargeList.remove(Value value)
Delete value from list. |
void |
LargeSet.remove(Value value)
Delete value from set. |
java.util.List<?> |
LargeList.scan()
Return all objects in the list. |
java.util.Map<?,?> |
LargeMap.scan()
Return all objects in the map. |
java.util.List<?> |
LargeSet.scan()
Return list of all objects in the set. |
java.util.List<?> |
LargeStack.scan()
Return list of all objects on the stack. |
void |
LargeList.setCapacity(int capacity)
Set maximum number of entries in the list. |
void |
LargeMap.setCapacity(int capacity)
Set maximum number of entries for the map. |
void |
LargeSet.setCapacity(int capacity)
Set maximum number of entries in the set. |
void |
LargeStack.setCapacity(int capacity)
Set maximum number of entries for the stack. |
int |
LargeList.size()
Return size of list. |
int |
LargeMap.size()
Return size of map. |
int |
LargeSet.size()
Return size of set. |
int |
LargeStack.size()
Return size of stack. |
Uses of AerospikeException in com.aerospike.client.listener |
---|
Methods in com.aerospike.client.listener with parameters of type AerospikeException | |
---|---|
void |
WriteListener.onFailure(AerospikeException exception)
This method is called when an asynchronous write command fails. |
void |
RecordListener.onFailure(AerospikeException exception)
This method is called when an asynchronous get or operate command fails. |
void |
DeleteListener.onFailure(AerospikeException exception)
This method is called when an asynchronous delete command fails. |
void |
ExistsSequenceListener.onFailure(AerospikeException exception)
This method is called when an asynchronous batch exists command fails. |
void |
ExistsListener.onFailure(AerospikeException exception)
This method is called when an asynchronous exists command fails. |
void |
ExistsArrayListener.onFailure(AerospikeException exception)
This method is called when an asynchronous exists command fails. |
void |
RecordArrayListener.onFailure(AerospikeException exception)
This method is called when an asynchronous batch get command fails. |
void |
RecordSequenceListener.onFailure(AerospikeException exception)
This method is called when an asynchronous batch get or scan command fails. |
Methods in com.aerospike.client.listener that throw AerospikeException | |
---|---|
void |
RecordSequenceListener.onRecord(Key key,
Record record)
This method is called when an asynchronous record is received from the server. |
Uses of AerospikeException in com.aerospike.client.query |
---|
Methods in com.aerospike.client.query that throw AerospikeException | |
---|---|
boolean |
RecordSet.next()
Retrieve next record. |
boolean |
ResultSet.next()
Retrieve next record. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |