StreamOperatorTaskFactory (samza-api 1.9.0-SNAPSHOT API)
JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev Class
Next Class
Frames
No Frames
All Classes
Summary: 
Nested | 
Field | 
Constr | 
Method
Detail: 
Field | 
Constr | 
Method
org.apache.samza.task
Interface StreamOperatorTaskFactory
All Superinterfaces:
java.io.Serializable, TaskFactory<AsyncStreamTask>
public interface StreamOperatorTaskFactory
extends TaskFactory<AsyncStreamTask>
Build AsyncStreamTask instances.
Implementations should return a new instance of AsyncStreamTask for each TaskFactory.createInstance() invocation.
Note: It returns an AsyncStreamTask since StreamOperatorTask is not part of samza-api. It is
a temporary hack introduced for SAMZA-2172 and will eventually go away with SAMZA-2203
Method Summary
Methods inherited from interface org.apache.samza.task.TaskFactory
createInstance
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev Class
Next Class
Frames
No Frames
All Classes
Summary: 
Nested | 
Field | 
Constr | 
Method
Detail: 
Field | 
Constr | 
Method