MockRemoteTaskFactory.MockRemoteTask(TaskId, PlanFragment, String, Executor, ScheduledExecutorService, Multimap, NodeTaskMap.NodeStatsTracker) |  | 0% | | n/a | 1 | 1 | 26 | 26 | 1 | 1 |
getTaskInfo() |  | 0% |  | 0% | 2 | 2 | 16 | 16 | 1 | 1 |
getTaskStatus() |  | 0% | | n/a | 1 | 1 | 20 | 20 | 1 | 1 |
getQueuedPartitionedSplitsInfo() |  | 0% |  | 0% | 5 | 5 | 14 | 14 | 1 | 1 |
getPartitionedSplitsInfo() |  | 0% |  | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
updateTaskStats() |  | 0% |  | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
finishSplits(int) |  | 0% |  | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
noMoreSplits(PlanNodeId) |  | 0% |  | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
updateSplitQueueSpace() |  | 0% |  | 0% | 5 | 5 | 6 | 6 | 1 | 1 |
addFinalTaskInfoListener(StateMachine.StateChangeListener) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
addSplits(Multimap) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
clearSplits() |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
startSplits(int) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
lambda$addFinalTaskInfoListener$3(AtomicBoolean, StateMachine.StateChangeListener, TaskState) |  | 0% |  | 0% | 3 | 3 | 3 | 3 | 1 | 1 |
setMaxUnacknowledgedSplits(int) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
setUnacknowledgedSplits(int) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
addStateChangeListener(StateMachine.StateChangeListener) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
start() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
abort() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$start$1(TaskState) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
lambda$new$0() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setOutputBuffers(OutputBuffers) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$addStateChangeListener$2(StateMachine.StateChangeListener, TaskState) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTaskId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
noMoreSplits(PlanNodeId, Lifespan) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
removeRemoteSource(TaskId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
whenSplitQueueHasSpace(long) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
cancel() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getNodeId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getRemoteTaskLocation() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getUnacknowledgedPartitionedSplitCount() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPlanFragment() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |