org.apache.samza.task

Interface StreamTaskFactory

All Superinterfaces:

java.io.Serializable, TaskFactory<StreamTask>

@InterfaceStability.Stable
public interface StreamTaskFactory
extends TaskFactory<StreamTask>

Build StreamTask instances.

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

Method Summary

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

createInstance