org.apache.samza.task

Interface StreamTaskFactory

@InterfaceStability.Stable
public interface StreamTaskFactory

Build StreamTask instances. Implementations should return a new instance for each createInstance() invocation.

Method Summary

Modifier and Type	Method and Description
StreamTask	createInstance()

Method Detail

createInstance

StreamTask createInstance()