Package org.apache.storm.daemon
Class Task
java.lang.Object
org.apache.storm.daemon.Task
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptiongetOutgoingTasks(Integer outTaskId, String stream, List<Object> values) getOutgoingTasks(String stream, List<Object> values) voidsendToEventLogger(Executor executor, List values, String componentId, Object messageId, Random random, Queue<AddressedTuple> overflow) Send sampled data to the eventlogger if the global or component level debug flag is set (via nimbus api).voidsendUnanchored(String stream, List<Object> values, ExecutorTransfer transfer, Queue<AddressedTuple> pendingEmits) toString()
- 
Constructor Details- 
Task- Throws:
- IOException
 
 
- 
- 
Method Details- 
getOutgoingTasks
- 
getOutgoingTasks
- 
getTuple
- 
getTaskId
- 
getComponentId
- 
getUserContext
- 
getTaskObject
- 
getTaskMetrics
- 
sendUnanchoredpublic void sendUnanchored(String stream, List<Object> values, ExecutorTransfer transfer, Queue<AddressedTuple> pendingEmits) 
- 
sendToEventLoggerpublic void sendToEventLogger(Executor executor, List values, String componentId, Object messageId, Random random, Queue<AddressedTuple> overflow) Send sampled data to the eventlogger if the global or component level debug flag is set (via nimbus api).
- 
toString
 
-