executor.submit(callbackQueue.poll().getCallback()); | executor.execute(callbackQueue.poll().getCallback()); | executor.submit(callbackQueue.poll().getCallback()) | executor.execute(callbackQueue.poll().getCallback()) | beam | ea564a01602abdd2b36005bc2eb1d630861c25e4 | org.apache.beam.runners.direct.WatermarkCallbackExecutor | | | TCIVar | executor |
---|
v1 | callbackQueue.poll().getCallback() |
---|
| | TCIVar | executor |
---|
v1 | callbackQueue.poll().getCallback() |
---|
| Uses | True |
executor.submit(callbackQueue.poll().getCallback()); | executor.execute(callbackQueue.poll().getCallback()); | executor.submit(callbackQueue.poll().getCallback()) | executor.execute(callbackQueue.poll().getCallback()) | beam | ee1297e21a481fbea52475c0732526a0441d03cb | org.apache.beam.runners.direct.WatermarkCallbackExecutor | | | TCIVar | executor |
---|
v1 | callbackQueue.poll().getCallback() |
---|
| | TCIVar | executor |
---|
v1 | callbackQueue.poll().getCallback() |
---|
| Uses | True |