| HttpRemoteTaskWithEventLoop(Session, TaskId, String, URI, URI, PlanFragment, Multimap, OutputBuffers, HttpClient, Duration, Duration, Duration, Duration, boolean, Codec, Codec, Codec, Codec, Codec, Codec, Codec, NodeTaskMap.NodeStatsTracker, RemoteTaskStats, boolean, boolean, boolean, boolean, boolean, Protocol, TableWriteInfo, int, MetadataManager, QueryManager, DecayCounter, boolean, HandleResolver, ConnectorTypeSerdeManager, SchedulerStatsTracker, SafeEventLoopGroup.SafeEventLoop) |  | 0% | | 0% | 6 | 6 | 97 | 97 | 1 | 1 |
| lambda$sendUpdate$10() | | 0% | | 0% | 17 | 17 | 55 | 55 | 1 | 1 |
| lambda$addSplits$3(Multimap) | | 0% | | 0% | 8 | 8 | 25 | 25 | 1 | 1 |
| processTaskUpdate(TaskInfo, List) | | 0% | | 0% | 8 | 8 | 25 | 25 | 1 | 1 |
| doScheduleAsyncCleanupRequest(Backoff, Request, String) | | 0% | | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
| onFailureTaskInfo(Throwable, String, Request, Backoff) | | 0% | | 0% | 5 | 5 | 14 | 14 | 1 | 1 |
| lambda$cleanUpTask$12() | | 0% | | 0% | 3 | 3 | 21 | 21 | 1 | 1 |
| createHttpRemoteTaskWithEventLoop(Session, TaskId, String, URI, URI, PlanFragment, Multimap, OutputBuffers, HttpClient, Duration, Duration, Duration, Duration, boolean, Codec, Codec, Codec, Codec, Codec, Codec, Codec, NodeTaskMap.NodeStatsTracker, RemoteTaskStats, boolean, boolean, boolean, boolean, boolean, Protocol, TableWriteInfo, int, MetadataManager, QueryManager, DecayCounter, boolean, HandleResolver, ConnectorTypeSerdeManager, SchedulerStatsTracker, SafeEventLoopGroup.SafeEventLoop) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| failTask(Throwable) | | 0% | | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
| lambda$cancel$11() | | 0% | | 0% | 3 | 3 | 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 |
| updateSplitQueueSpace() | | 0% | | 0% | 6 | 6 | 6 | 6 | 1 | 1 |
| lambda$abort$13(TaskStatus) | | 0% | | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
| lambda$whenSplitQueueHasSpace$8(long, SettableFuture) | | 0% | | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
| removeRemoteSource(TaskId) | | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
| getPartitionedSplitsInfo() | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| getQueuedPartitionedSplitsInfo() | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| logError(Throwable, String, Object[]) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| getExceededTaskUpdateSizeMessage(byte[]) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| doRemoveRemoteSource(RequestErrorTracker, Request, SettableFuture) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| safeExecuteOnEventLoop(Runnable, String) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$noMoreSplits$4(PlanNodeId) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| lambda$initialize$1(TaskStatus) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| addSplits(Multimap) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| whenSplitQueueHasSpace(long) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| scheduleAsyncCleanupRequest(Backoff, Request, String) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| onSuccessTaskInfo(TaskInfo) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| getSources() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| lambda$setOutputBuffers$6(OutputBuffers) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| getQueuedPartitionedSplitsWeight() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| getHttpUriBuilder(TaskStatus) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| updateTaskInfo(TaskInfo) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| abort() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| initialize() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| setOutputBuffers(OutputBuffers) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| cleanUpLocally() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| scheduleUpdate() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| lambda$noMoreSplits$5(PlanNodeId, Lifespan) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| lambda$start$2() | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| getUnacknowledgedPartitionedSplitsInfo() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$new$0(OutputBuffers.OutputBufferId) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| noMoreSplits(PlanNodeId, Lifespan) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| noMoreSplits(PlanNodeId) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| abort(TaskStatus) | | 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 |
| start() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| sendUpdate() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| cancel() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| cleanUpTask() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$onFailureTaskInfo$9(Backoff, Request, String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| addStateChangeListener(StateMachine.StateChangeListener) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| addFinalTaskInfoListener(StateMachine.StateChangeListener) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$null$7(SettableFuture) | | 0% | | n/a | 1 | 1 | 1 | 1 | 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 |