Package org.apache.storm.daemon
Class Task
java.lang.Object
org.apache.storm.daemon.Task
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptiongetOutgoingTasks
(Integer outTaskId, String stream, List<Object> values) getOutgoingTasks
(String stream, List<Object> values) 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).void
sendUnanchored
(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
-
sendUnanchored
public void sendUnanchored(String stream, List<Object> values, ExecutorTransfer transfer, Queue<AddressedTuple> pendingEmits) -
sendToEventLogger
public 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
-