| 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 |