org.apache.samza.task

Interface AsyncStreamTaskFactory

All Superinterfaces:

java.io.Serializable, TaskFactory<AsyncStreamTask>

@InterfaceStability.Stable
public interface AsyncStreamTaskFactory
extends TaskFactory<AsyncStreamTask>

Build AsyncStreamTask instances.

Implementations should return a new instance of AsyncStreamTask for each TaskFactory.createInstance() invocation.

Method Summary

Methods inherited from interface org.apache.samza.task.TaskFactory

createInstance