org.apache.samza.table.remote

Class BaseTableFunction

java.lang.Object

org.apache.samza.table.remote.BaseTableFunction

All Implemented Interfaces:

java.io.Serializable, ClosableFunction, TableFunction, TablePart

public abstract class BaseTableFunction
extends java.lang.Object
implements TableFunction

Base class for all table read and write functions.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected AsyncReadWriteTable	table

Constructor Summary

Constructors

Constructor and Description
BaseTableFunction()

Method Summary

Modifier and Type	Method and Description
void	init(Context context, AsyncReadWriteTable table) Initializes the function before any operation.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

isRetriable

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

toConfig

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

close

Field Detail

table

protected transient AsyncReadWriteTable table

Constructor Detail

BaseTableFunction

public BaseTableFunction()

Method Detail

init

public void init(Context context,
                 AsyncReadWriteTable table)

Description copied from interface: TableFunction

Initializes the function before any operation.

Specified by:

init in interface TableFunction

Parameters:

context - the Context for this task

table - the TableFunction which this table function belongs to