| schedule() |  | 0% | | 0% | 37 | 37 | 80 | 80 | 1 | 1 |
| assignSplits(Multimap, Multimap) | | 0% | | 0% | 3 | 3 | 16 | 16 | 1 | 1 |
| drainCompletelyScheduledLifespans() | | 0% | | 0% | 6 | 6 | 14 | 14 | 1 | 1 |
| SourcePartitionedScheduler(SqlStageExecution, PlanNodeId, SplitSource, SplitPlacementPolicy, int, boolean) | | 0% | | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
| startLifespan(Lifespan, ConnectorPartitionHandle) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| finalizeTaskCreationIfNecessary() | | 0% | | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
| rewindLifespan(Lifespan, ConnectorPartitionHandle) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| newSourcePartitionedSchedulerAsStageScheduler(SqlStageExecution, PlanNodeId, SplitSource, SplitPlacementPolicy, int) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| notifyAllLifespansFinishedExecution() | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| dropListenersFromWhenFinishedOrNewLifespansAdded() | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| newSourcePartitionedSchedulerAsSourceScheduler(SqlStageExecution, PlanNodeId, SplitSource, SplitPlacementPolicy, int, boolean) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$finalizeTaskCreationIfNecessary$2(InternalNode) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$finalizeTaskCreationIfNecessary$1(Set, InternalNode) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$schedule$0(long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| close() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getPlanNodeId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |