Package org.apache.storm.trident.planner
Class ProcessorNode
java.lang.Object
org.apache.storm.trident.operation.DefaultResourceDeclarer<Node>
org.apache.storm.trident.planner.Node
org.apache.storm.trident.planner.ProcessorNode
- All Implemented Interfaces:
Serializable
,ResourceDeclarer<Node>
,ITridentResource
- See Also:
-
Field Summary
Modifier and TypeFieldDescriptionboolean
Fields inherited from class org.apache.storm.trident.planner.Node
allOutputFields, creationIndex, name, parallelismHint, stateInfo, streamId
-
Constructor Summary
ConstructorDescriptionProcessorNode
(String streamId, String name, Fields allOutputFields, Fields selfOutFields, TridentProcessor processor) -
Method Summary
Methods inherited from class org.apache.storm.trident.operation.DefaultResourceDeclarer
addSharedMemory, getResources, getSharedMemory, setCPULoad, setMemoryLoad, setMemoryLoad
-
Field Details
-
committer
public boolean committer -
processor
-
selfOutFields
-
-
Constructor Details
-
ProcessorNode
public ProcessorNode(String streamId, String name, Fields allOutputFields, Fields selfOutFields, TridentProcessor processor)
-
-
Method Details
-
shortString
- Overrides:
shortString
in classNode
-