| processInternal(OperationTimer) |  | 0% | | 0% | 33 | 33 | 87 | 87 | 1 | 1 |
| Driver(DriverContext, List) | | 0% | | 0% | 10 | 10 | 37 | 37 | 1 | 1 |
| processNewSources() | | 0% | | 0% | 11 | 11 | 35 | 35 | 1 | 1 |
| closeAndDestroyOperators(List) | | 0% | | 0% | 3 | 3 | 21 | 21 | 1 | 1 |
| destroyIfNecessary() | | 0% | | 0% | 6 | 6 | 20 | 20 | 1 | 1 |
| tryWithLock(long, TimeUnit, Supplier) | | 0% | | 0% | 6 | 6 | 15 | 15 | 1 | 1 |
| lambda$processFor$10(long) | | 0% | | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
| handleMemoryRevoke() | | 0% | | 0% | 5 | 5 | 9 | 9 | 1 | 1 |
| getBlockedFuture(Operator) | | 0% | | 0% | 5 | 5 | 13 | 13 | 1 | 1 |
| isFinishedInternal() | | 0% | | 0% | 6 | 6 | 5 | 5 | 1 | 1 |
| processFor(Duration) | | 0% | | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
| updateSource(TaskSource) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| createTimer() | | 0% | | 0% | 5 | 5 | 5 | 5 | 1 | 1 |
| updateDriverBlockedFuture(ListenableFuture) | | 0% | | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
| firstFinishedFuture(List) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| process() | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| createDriver(DriverContext, Operator, Operator[]) | | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
| shouldUseFragmentResultCache() | | 0% | | 0% | 4 | 4 | 1 | 1 | 1 | 1 |
| checkOperatorFinishedRevoking(Operator) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| addSuppressedException(Throwable, Throwable, String, Object[]) | | 0% | | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
| close() | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| createDriver(DriverContext, List) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| isFinished() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$isFinished$4() | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| checkLockNotHeld(String) | | 0% | | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
| initialize() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| lambda$updateDriverBlockedFuture$13(Operator) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$process$11() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$updateSource$5(TaskSource, TaskSource) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$null$1() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$new$0(SourceOperator) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| checkLockHeld(String) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| tryWithLock(Supplier) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getSourceId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$firstFinishedFuture$15(SettableFuture) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$updateDriverBlockedFuture$12(SettableFuture) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$processNewSources$7(Split, FragmentResultCacheContext) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$initialize$2(OperatorContext) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$processNewSources$9(Supplier, UpdateOperator) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$processNewSources$8(Supplier, DeleteOperator) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| static {...} | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getDriverContext() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$processInternal$14(int) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$updateSource$6() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$close$3() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |