Package org.apache.storm.trident.planner
Class SpoutNode
java.lang.Object
org.apache.storm.trident.operation.DefaultResourceDeclarer<Node>
org.apache.storm.trident.planner.Node
org.apache.storm.trident.planner.SpoutNode
- All Implemented Interfaces:
Serializable
,ResourceDeclarer<Node>
,ITridentResource
- See Also:
-
Nested Class Summary
-
Field Summary
Fields inherited from class org.apache.storm.trident.planner.Node
allOutputFields, creationIndex, name, parallelismHint, stateInfo, streamId
-
Constructor Summary
-
Method Summary
Methods inherited from class org.apache.storm.trident.planner.Node
equals, hashCode, shortString, toString
Methods inherited from class org.apache.storm.trident.operation.DefaultResourceDeclarer
addSharedMemory, getResources, getSharedMemory, setCPULoad, setMemoryLoad, setMemoryLoad
-
Field Details
-
spout
-
txId
-
type
-
-
Constructor Details
-
SpoutNode
public SpoutNode(String streamId, Fields allOutputFields, String txid, Object spout, SpoutNode.SpoutType type)
-