HttpRemoteTask

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,983 of 1,9830%146 of 1460%1241244424425151
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)4680%100%6610810811
sendUpdate()2810%320%1717565611
addSplits(Multimap)1150%160%99282811
processTaskUpdate(TaskInfo, List)1010%140%88242411
cleanUpTask()710%40%33212111
doScheduleAsyncCleanupRequest(Backoff, Request, String)710%40%339911
onFailureTaskInfo(Throwable, String, Request, Backoff)690%80%55131311
cancel()580%40%33121211
abort(TaskStatus)520%20%22111111
updateTaskStats()430%20%229911
createCleanupBackoff()430%n/a117711
getSource(PlanNodeId)420%60%448811
failTask(Throwable)410%20%227711
updateSplitQueueSpace()350%100%665511
removeRemoteSource(TaskId)340%n/a11111111
getPartitionedSplitsInfo()340%20%227711
whenSplitQueueHasSpace(long)320%60%447711
getQueuedPartitionedSplitsInfo()280%20%227711
start()270%n/a116611
setOutputBuffers(OutputBuffers)260%40%337711
logError(Throwable, String, Object[])230%20%224411
noMoreSplits(PlanNodeId)200%20%226611
doRemoveRemoteSource(RequestErrorTracker, Request, SettableFuture)190%n/a114411
addStateChangeListener(StateMachine.StateChangeListener)190%n/a113311
getExceededTaskUpdateSizeMessage(byte[])170%n/a111111
getSources()160%n/a114411
getQueuedPartitionedSplitsWeight()150%20%224411
getHttpUriBuilder(TaskStatus)150%20%224411
abort()140%20%224411
lambda$new$1(TaskStatus)140%20%226611
noMoreSplits(PlanNodeId, Lifespan)130%20%224411
scheduleAsyncCleanupRequest(Backoff, Request, String)130%20%224411
onSuccessTaskInfo(TaskInfo)120%20%224411
scheduleUpdate()110%n/a113311
getUnacknowledgedPartitionedSplitsInfo()100%n/a113311
updateTaskInfo(TaskInfo)100%n/a113311
lambda$new$0(OutputBuffers.OutputBufferId)90%n/a111111
cleanUpLocally()80%n/a112211
toString()70%n/a113311
static {...}70%n/a112211
lambda$onFailureTaskInfo$2(Backoff, Request, String)60%n/a111111
addFinalTaskInfoListener(StateMachine.StateChangeListener)50%n/a112211
getTaskInfo()40%n/a111111
getTaskStatus()40%n/a111111
getPlanFragment()0%n/a111111
getTaskId()0%n/a111111
getNodeId()0%n/a111111
getRemoteTaskLocation()0%n/a111111
getUnacknowledgedPartitionedSplitCount()0%n/a111111
getPendingSourceSplitCount()0%n/a111111
getPendingSourceSplitsWeight()0%n/a111111