HttpRemoteTask(Session, TaskId, String, URI, URI, PlanFragment, Multimap, OutputBuffers, HttpClient, Executor, ScheduledExecutorService, ScheduledExecutorService, Duration, Duration, Duration, Duration, boolean, Codec, Codec, Codec, Codec, Codec, Codec, Codec, NodeTaskMap.NodeStatsTracker, RemoteTaskStats, boolean, boolean, boolean, boolean, boolean, Protocol, TableWriteInfo, long, MetadataManager, QueryManager, DecayCounter, boolean, HandleResolver, ConnectorTypeSerdeManager, SchedulerStatsTracker) |  | 0% |  | 0% | 6 | 6 | 108 | 108 | 1 | 1 |
sendUpdate() |  | 0% |  | 0% | 17 | 17 | 56 | 56 | 1 | 1 |
addSplits(Multimap) |  | 0% |  | 0% | 9 | 9 | 28 | 28 | 1 | 1 |
processTaskUpdate(TaskInfo, List) |  | 0% |  | 0% | 8 | 8 | 24 | 24 | 1 | 1 |
cleanUpTask() |  | 0% |  | 0% | 3 | 3 | 21 | 21 | 1 | 1 |
doScheduleAsyncCleanupRequest(Backoff, Request, String) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
onFailureTaskInfo(Throwable, String, Request, Backoff) |  | 0% |  | 0% | 5 | 5 | 13 | 13 | 1 | 1 |
cancel() |  | 0% |  | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
abort(TaskStatus) |  | 0% |  | 0% | 2 | 2 | 11 | 11 | 1 | 1 |
updateTaskStats() |  | 0% |  | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
createCleanupBackoff() |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
getSource(PlanNodeId) |  | 0% |  | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
failTask(Throwable) |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
updateSplitQueueSpace() |  | 0% |  | 0% | 6 | 6 | 5 | 5 | 1 | 1 |
removeRemoteSource(TaskId) |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
getPartitionedSplitsInfo() |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
whenSplitQueueHasSpace(long) |  | 0% |  | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
getQueuedPartitionedSplitsInfo() |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
start() |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
setOutputBuffers(OutputBuffers) |  | 0% |  | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
logError(Throwable, String, Object[]) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
noMoreSplits(PlanNodeId) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
doRemoveRemoteSource(RequestErrorTracker, Request, SettableFuture) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
addStateChangeListener(StateMachine.StateChangeListener) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getExceededTaskUpdateSizeMessage(byte[]) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getSources() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
getQueuedPartitionedSplitsWeight() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
getHttpUriBuilder(TaskStatus) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
abort() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
lambda$new$1(TaskStatus) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
noMoreSplits(PlanNodeId, Lifespan) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
scheduleAsyncCleanupRequest(Backoff, Request, String) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
onSuccessTaskInfo(TaskInfo) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
scheduleUpdate() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getUnacknowledgedPartitionedSplitsInfo() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
updateTaskInfo(TaskInfo) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$new$0(OutputBuffers.OutputBufferId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
cleanUpLocally() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
toString() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$onFailureTaskInfo$2(Backoff, Request, String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
addFinalTaskInfoListener(StateMachine.StateChangeListener) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getTaskInfo() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTaskStatus() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPlanFragment() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTaskId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 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 |
getPendingSourceSplitCount() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPendingSourceSplitsWeight() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |