()
| 203 | } |
| 204 | |
| 205 | public TaskMetrics getTaskMetrics() { |
| 206 | return taskMetrics; |
| 207 | } |
| 208 | |
| 209 | // Non Blocking call. If cannot emit to destination immediately, such tuples will be added to `pendingEmits` argument |
| 210 | public void sendUnanchored(String stream, List<Object> values, ExecutorTransfer transfer, Queue<AddressedTuple> pendingEmits) { |