org.apache.samza.table

Interface ReadWriteTable<K,V>

Type Parameters:

K - the type of the key in this table

V - the type of the value in this table

All Superinterfaces:

ReadableTable<K,V>, Table<KV<K,V>>

@InterfaceStability.Unstable
public interface ReadWriteTable<K,V>
extends ReadableTable<K,V>

A table that supports get, put and delete by one or more keys

Method Summary

Modifier and Type	Method and Description
void	delete(K key) Deletes the mapping for the specified key from this table (if such mapping exists).
void	deleteAll(java.util.List<K> keys) Deletes the mappings for the specified keys from this table.
java.util.concurrent.CompletableFuture<java.lang.Void>	deleteAllAsync(java.util.List<K> keys) Asynchronously deletes the mappings for the specified keys from this table.
java.util.concurrent.CompletableFuture<java.lang.Void>	deleteAsync(K key) 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.
void	put(K key, V value) Updates the mapping of the specified key-value pair; Associates the specified key with the specified value.
void	putAll(java.util.List<Entry<K,V>> entries) Updates the mappings of the specified key-value entries.
java.util.concurrent.CompletableFuture<java.lang.Void>	putAllAsync(java.util.List<Entry<K,V>> entries) Asynchronously updates the mappings of the specified key-value entries.
java.util.concurrent.CompletableFuture<java.lang.Void>	putAsync(K key, V value) Asynchronously updates the mapping of the specified key-value pair; Associates the specified key with the specified value.

Methods inherited from interface org.apache.samza.table.ReadableTable

close, get, getAll, getAllAsync, getAsync, init

Method Detail

put

void put(K key,
         V value)

Updates the mapping of the specified key-value pair; Associates the specified key with the specified value. The key is deleted from the table if value is null.

Parameters:

key - the key with which the specified value is to be associated.

value - the value with which the specified key is to be associated.

Throws:

java.lang.NullPointerException - if the specified key is null.

putAsync

java.util.concurrent.CompletableFuture<java.lang.Void> putAsync(K key,
                                                                V value)

Asynchronously updates the mapping of the specified key-value pair; Associates the specified key with the specified value. The key is deleted from the table if value is null.

Parameters:

key - the key with which the specified value is to be associated.

value - the value with which the specified key is to be associated.

Returns:

CompletableFuture for the operation

Throws:

java.lang.NullPointerException - if the specified key is null.

putAll

void putAll(java.util.List<Entry<K,V>> entries)

Updates the mappings of the specified key-value entries. A key is deleted from the table if its corresponding value is null.

Parameters:

entries - the updated mappings to put into this table.

Throws:

java.lang.NullPointerException - if any of the specified entries has null as key.

putAllAsync

java.util.concurrent.CompletableFuture<java.lang.Void> putAllAsync(java.util.List<Entry<K,V>> entries)

Asynchronously updates the mappings of the specified key-value entries. A key is deleted from the table if its corresponding value is null.

Parameters:

entries - the updated mappings to put into this table.

Returns:

CompletableFuture for the operation

Throws:

java.lang.NullPointerException - if any of the specified entries has null as key.

delete

void delete(K key)

Deletes the mapping for the specified key from this table (if such mapping exists).

Parameters:

key - the key for which the mapping is to be deleted.

Throws:

java.lang.NullPointerException - if the specified key is null.

deleteAsync

java.util.concurrent.CompletableFuture<java.lang.Void> deleteAsync(K key)

Asynchronously deletes the mapping for the specified key from this table (if such mapping exists).

Parameters:

key - the key for which the mapping is to be deleted.

Returns:

CompletableFuture for the operation

Throws:

java.lang.NullPointerException - if the specified key is null.

deleteAll

void deleteAll(java.util.List<K> keys)

Deletes the mappings for the specified keys from this table.

Parameters:

keys - the keys for which the mappings are to be deleted.

Throws:

java.lang.NullPointerException - if the specified keys list, or any of the keys, is null.

deleteAllAsync

java.util.concurrent.CompletableFuture<java.lang.Void> deleteAllAsync(java.util.List<K> keys)

Asynchronously deletes the mappings for the specified keys from this table.

Parameters:

keys - the keys for which the mappings are to be deleted.

Returns:

CompletableFuture for the operation

Throws:

java.lang.NullPointerException - if the specified keys list, or any of the keys, is null.

flush

void flush()

Flushes the underlying store of this table, if applicable.