org.apache.samza.task

Interface TaskFactory<T>

Type Parameters:

T - the type of task instances created by the factory

All Superinterfaces:

java.io.Serializable

All Known Subinterfaces:

AsyncStreamTaskFactory, StreamTaskFactory

@InterfaceStability.Stable
public interface TaskFactory<T>
extends java.io.Serializable

The base interface for all task factories (i.e. StreamTaskFactory and AsyncStreamTaskFactory)

Method Summary

Modifier and Type	Method and Description
T	createInstance() Create instance of task

Method Detail

createInstance

T createInstance()

Create instance of task

Returns:

task of type T