K
- the type of the key in this tableV
- the type of the value in this tablepublic interface AsyncReadWriteTable<K,V> extends Table
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the table and release any resources acquired
|
java.util.concurrent.CompletableFuture<java.lang.Void> |
deleteAllAsync(java.util.List<K> keys,
java.lang.Object... args)
Asynchronously deletes the mappings for the specified
keys from this table. |
java.util.concurrent.CompletableFuture<java.lang.Void> |
deleteAsync(K key,
java.lang.Object... args)
Asynchronously deletes the mapping for the specified
key from this table (if such mapping exists). |
void |
flush()
Flushes the underlying store of this table, if applicable.
|
java.util.concurrent.CompletableFuture<java.util.Map<K,V>> |
getAllAsync(java.util.List<K> keys,
java.lang.Object... args)
Asynchronously gets the values with which the specified
keys are associated. |
java.util.concurrent.CompletableFuture<V> |
getAsync(K key,
java.lang.Object... args)
Asynchronously gets the value associated with the specified
key . |
default void |
init(Context context)
Initializes the table during container initialization.
|
java.util.concurrent.CompletableFuture<java.lang.Void> |
putAllAsync(java.util.List<Entry<K,V>> entries,
java.lang.Object... args)
Asynchronously updates the mappings of the specified key-value
entries . |
java.util.concurrent.CompletableFuture<java.lang.Void> |
putAsync(K key,
V value,
java.lang.Object... args)
Asynchronously updates the mapping of the specified key-value pair;
Associates the specified
key with the specified value . |
default <T> java.util.concurrent.CompletableFuture<T> |
readAsync(int opId,
java.lang.Object... args)
Asynchronously executes a read operation.
|
default <T> java.util.concurrent.CompletableFuture<T> |
writeAsync(int opId,
java.lang.Object... args)
Asynchronously executes a write operation.
|
java.util.concurrent.CompletableFuture<V> getAsync(K key, java.lang.Object... args)
key
.key
- the key with which the associated value is to be fetched.args
- additional argumentsjava.lang.NullPointerException
- if the specified key
is null
.java.util.concurrent.CompletableFuture<java.util.Map<K,V>> getAllAsync(java.util.List<K> keys, java.lang.Object... args)
keys
are associated.keys
- the keys with which the associated values are to be fetched.args
- additional argumentsjava.lang.NullPointerException
- if the specified keys
list, or any of the keys, is null
.default <T> java.util.concurrent.CompletableFuture<T> readAsync(int opId, java.lang.Object... args)
T
- return typeopId
- operation identifierargs
- additional argumentsjava.util.concurrent.CompletableFuture<java.lang.Void> putAsync(K key, V value, java.lang.Object... args)
key
with the specified value
.
The key is deleted from the table if value is null
.key
- the key with which the specified value
is to be associated.value
- the value with which the specified key
is to be associated.args
- additional argumentsjava.lang.NullPointerException
- if the specified key
is null
.java.util.concurrent.CompletableFuture<java.lang.Void> putAllAsync(java.util.List<Entry<K,V>> entries, java.lang.Object... args)
entries
.
A key is deleted from the table if its corresponding value is null
.entries
- the updated mappings to put into this table.args
- additional argumentsjava.lang.NullPointerException
- if any of the specified entries
has null
as key.java.util.concurrent.CompletableFuture<java.lang.Void> deleteAsync(K key, java.lang.Object... args)
key
from this table (if such mapping exists).key
- the key for which the mapping is to be deleted.args
- additional argumentsjava.lang.NullPointerException
- if the specified key
is null
.java.util.concurrent.CompletableFuture<java.lang.Void> deleteAllAsync(java.util.List<K> keys, java.lang.Object... args)
keys
from this table.keys
- the keys for which the mappings are to be deleted.args
- additional argumentsjava.lang.NullPointerException
- if the specified keys
list, or any of the keys, is null
.default <T> java.util.concurrent.CompletableFuture<T> writeAsync(int opId, java.lang.Object... args)
T
- return typeopId
- operation identifierargs
- additional argumentsdefault void init(Context context)
context
- Context
corresponding to this tablevoid flush()
void close()