Github user roshannaik commented on a diff in the pull request:
https://github.com/apache/storm/pull/2241#discussion_r158924067
--- Diff: storm-client/src/jvm/org/apache/storm/daemon/Task.java ---
@@ -177,6 +196,35 @@ public BuiltinMetrics getBuiltInMetrics() {
return builtInMetrics;
}
+
+ // Non Blocking call. If cannot emmit to destination immediately, such
tuples will be added to `pendingEmits` argument
+ public void sendUnanchored(String stream, List<Object> values,
ExecutorTransfer transfer, Queue<AddressedTuple> pendingEmits) {
+ Tuple tuple = getTuple(stream, values);
+ List<Integer> tasks = getOutgoingTasks(stream, values);
+ for (Integer t : tasks) {
+ AddressedTuple addressedTuple = new AddressedTuple(t, tuple);
+ transfer.tryTransfer(addressedTuple, pendingEmits);
+ }
+ }
+
+ /**
+ * Send sampled data to the eventlogger if the global or component
level debug flag is set (via nimbus api).
+ */
+ public void sendToEventLogger(Executor executor, List values,
--- End diff --
Agree. Since topology.eventlogger.executors=0 (disabled) by default, i
didn't spend time on this.
---
