SqlTaskExecution(TaskStateMachine, TaskContext, OutputBuffer, LocalExecutionPlanner.LocalExecutionPlan, TaskExecutor, SplitMonitor, Executor) |  | 0% |  | 0% | 9 | 9 | 50 | 50 | 1 | 1 |
scheduleTableScanSource(TaskSource) |  | 0% |  | 0% | 10 | 10 | 35 | 35 | 1 | 1 |
addSources(List) |  | 0% |  | 0% | 6 | 6 | 19 | 19 | 1 | 1 |
mergeIntoPendingSplits(PlanNodeId, Set, Set, boolean) |  | 0% |  | 0% | 4 | 4 | 18 | 18 | 1 | 1 |
updateSources(List) |  | 0% |  | 0% | 4 | 4 | 19 | 19 | 1 | 1 |
scheduleDriversForDriverGroupLifeCycle(Lifespan) |  | 0% |  | 0% | 5 | 5 | 13 | 13 | 1 | 1 |
scheduleDriversForTaskLifeCycle() |  | 0% |  | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
enqueueDriverSplitRunner(boolean, List) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
getNoMoreSplits() |  | 0% |  | 0% | 5 | 5 | 10 | 10 | 1 | 1 |
checkTaskCompletion() |  | 0% |  | 0% | 6 | 6 | 13 | 13 | 1 | 1 |
createSqlTaskExecution(TaskStateMachine, TaskContext, OutputBuffer, List, LocalExecutionPlanner.LocalExecutionPlan, TaskExecutor, Executor, SplitMonitor) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
scheduleRemoteSource(TaskSource, Map) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
checkLifespan(PipelineExecutionStrategy, Lifespan) |  | 0% |  | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
createTaskHandle(TaskStateMachine, TaskContext, OutputBuffer, LocalExecutionPlanner.LocalExecutionPlan, TaskExecutor) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
lambda$createTaskHandle$2(TaskExecutor, TaskHandle, LocalExecutionPlanner.LocalExecutionPlan, TaskState) |  | 0% |  | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
lambda$updateSources$4(long, TaskSource) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
checkHoldsLock() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
toString() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
lambda$null$3(long, ScheduledSplit) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$new$0(PlanNodeId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$mergeIntoPendingSplits$6(ScheduledSplit) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$updateSources$5(TaskSource) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$new$1(SqlTaskExecution.Status, Lifespan) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTaskId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTaskContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |