Github user roshannaik commented on a diff in the pull request: https://github.com/apache/storm/pull/2502#discussion_r160011014 --- Diff: storm-client/src/jvm/org/apache/storm/daemon/Task.java --- @@ -177,6 +195,35 @@ public BuiltinMetrics getBuiltInMetrics() { return builtInMetrics; } + + // Non Blocking call. If cannot emit 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 -- @HeartSaVioR you pointed out some optimizations are possible to this .. that we can tackle in another jira ... can you elaborate or capture your thoughts into a jira ?
---