org.apache.samza.table.remote

Interface TableFunction

All Superinterfaces:

ClosableFunction, java.io.Serializable, TablePart

All Known Subinterfaces:

TableReadFunction<K,V>, TableWriteFunction<K,V>

All Known Implementing Classes:

BaseTableFunction

@InterfaceStability.Unstable
public interface TableFunction
extends TablePart, ClosableFunction, java.io.Serializable

The root interface for table read and write function.

Method Summary

Modifier and Type	Method and Description
void	init(Context context, AsyncReadWriteTable table) Initializes the function before any operation.
boolean	isRetriable(java.lang.Throwable exception) Determine whether the current operation can be retried with the last thrown exception.

Methods inherited from interface org.apache.samza.table.remote.TablePart

toConfig

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

close

Method Detail

init

void init(Context context,
          AsyncReadWriteTable table)

Initializes the function before any operation.

Parameters:

context - the Context for this task

table - the TableFunction which this table function belongs to

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