org.apache.samza.table.remote

Interface TableWriteFunction<K,V>

Type Parameters:

K - the type of the key in this table

V - the type of the value in this table

All Superinterfaces:

ClosableFunction, InitableFunction, java.io.Serializable

@InterfaceStability.Unstable
public interface TableWriteFunction<K,V>
extends java.io.Serializable, InitableFunction, ClosableFunction

A function object to be used with a remote read/write table implementation. It encapsulates the functionality of writing table record(s) for a provided set of key(s) to the store.

Instances of TableWriteFunction are meant to be serializable. ie. any non-serializable state (eg: network sockets) should be marked as transient and recreated inside readObject().

Implementations are expected to be thread-safe.

Method Summary

Modifier and Type	Method and Description
default void	delete(K key) Delete the record with specified key from the remote store.
default void	deleteAll(java.util.Collection<K> keys) Delete all records with the specified keys from the remote store The default implementation calls deleteAllAsync and blocks on the completion afterwards.
default java.util.concurrent.CompletableFuture<java.lang.Void>	deleteAllAsync(java.util.Collection<K> keys) Asynchronously delete all records with the specified keys from the remote store.
java.util.concurrent.CompletableFuture<java.lang.Void>	deleteAsync(K key) Asynchronously delete the record with specified key from the remote store
default void	flush() Flush the remote store (optional)
boolean	isRetriable(java.lang.Throwable exception) Determine whether the current operation can be retried with the last thrown exception.
default void	put(K key, V record) Store single table record with specified key.
default void	putAll(java.util.List<Entry<K,V>> records) Store the table records with specified keys.
default java.util.concurrent.CompletableFuture<java.lang.Void>	putAllAsync(java.util.Collection<Entry<K,V>> records) Asynchronously store the table records with specified keys.
java.util.concurrent.CompletableFuture<java.lang.Void>	putAsync(K key, V record) Asynchronously store single table record with specified key.

Methods inherited from interface org.apache.samza.operators.functions.InitableFunction

init

Methods inherited from interface org.apache.samza.operators.functions.ClosableFunction

close

Method Detail

put

default void put(K key,
                 V record)

Store single table record with specified key. This method must be thread-safe. The default implementation calls putAsync and blocks on the completion afterwards.

Parameters:

key - key for the table record

record - table record to be written

putAsync

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

Asynchronously store single table record with specified key. This method must be thread-safe.

Parameters:

key - key for the table record

record - table record to be written

Returns:

CompletableFuture for the put request

putAll

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

Store the table records with specified keys. This method must be thread-safe. The default implementation calls putAllAsync and blocks on the completion afterwards.

Parameters:

records - table records to be written

putAllAsync

default java.util.concurrent.CompletableFuture<java.lang.Void> putAllAsync(java.util.Collection<Entry<K,V>> records)

Asynchronously store the table records with specified keys. This method must be thread-safe. The default implementation calls putAsync for each entry and return a combined future.

Parameters:

records - table records to be written

Returns:

CompletableFuture for the put request

delete

default void delete(K key)

Delete the record with specified key from the remote store. The default implementation calls deleteAsync and blocks on the completion afterwards.

Parameters:

key - key to the table record to be deleted

deleteAsync

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

Asynchronously delete the record with specified key from the remote store

Parameters:

key - key to the table record to be deleted

Returns:

CompletableFuture for the delete request

deleteAll

default void deleteAll(java.util.Collection<K> keys)

Delete all records with the specified keys from the remote store The default implementation calls deleteAllAsync and blocks on the completion afterwards.

Parameters:

keys - keys for the table records to be written

deleteAllAsync

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

Asynchronously delete all records with the specified keys from the remote store. The default implementation calls deleteAsync for each key and return a combined future.

Parameters:

keys - keys for the table records to be written

Returns:

CompletableFuture for the deleteAll request

isRetriable

boolean isRetriable(java.lang.Throwable exception)

Determine whether the current operation can be retried with the last thrown exception.

Parameters:

exception - exception thrown by a table operation

Returns:

whether the operation can be retried

flush

default void flush()

Flush the remote store (optional)