testBalancedSplitAssignment() |  | 0% |  | 0% | 2 | 2 | 33 | 33 | 1 | 1 |
testScheduleSplitsBlock() |  | 0% |  | 0% | 9 | 9 | 31 | 31 | 1 | 1 |
testBlockCausesFullSchedule() |  | 0% |  | 0% | 3 | 3 | 28 | 28 | 1 | 1 |
createPlan() |  | 0% | | n/a | 1 | 1 | 29 | 29 | 1 | 1 |
testScheduleSplitsOneAtATime() |  | 0% |  | 0% | 6 | 6 | 19 | 19 | 1 | 1 |
testScheduleSplitsBatched() |  | 0% |  | 0% | 5 | 5 | 19 | 19 | 1 | 1 |
testNoNodes() |  | 0% | | n/a | 1 | 1 | 15 | 15 | 1 | 1 |
TestSourcePartitionedScheduler() |  | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
getSourcePartitionedScheduler(ConnectorSplitSource, SqlStageExecution, InternalNodeManager, NodeTaskMap, int) |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
testScheduleSlowSplitSource() |  | 0% | | n/a | 1 | 1 | 13 | 13 | 1 | 1 |
createSqlStageExecution(SubPlan, NodeTaskMap) |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
testScheduleNoSplits() |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
assertEffectivelyFinished(ScheduleResult, StageScheduler) |  | 0% |  | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
createFixedSplitSource(int, Supplier) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
destroyExecutor() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
assertPartitionedSplitCount(SqlStageExecution, int) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setUp() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$assertPartitionedSplitCount$0(RemoteTask) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |