SqlTaskManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total981 of 9810%40 of 400%59592012013939
SqlTaskManager(LocalExecutionPlanner, LocationFactory, TaskExecutor, SplitMonitor, NodeInfo, LocalMemoryManager, JsonCodec, TaskManagementExecutor, TaskManagerConfig, NodeMemoryConfig, LocalSpillManager, ExchangeClientSupplier, NodeSpillConfig, GcMonitor, BlockEncodingSerde, OrderingCompiler, FragmentResultCacheManager, ObjectMapper, SpoolingOutputBufferFactory)1440%n/a11262611
updateTask(Session, TaskId, Optional, List, OutputBuffers, Optional)980%40%33232311
updateMemoryPoolAssignments(MemoryPoolAssignmentsRequest)940%80%55161611
failAbandonedTasks()930%80%55161611
removeOldTasks()580%60%44111111
close()570%60%44151511
getTaskResults(TaskId, OutputBuffers.OutputBufferId, long, long)320%20%225511
acknowledgeTaskResults(TaskId, OutputBuffers.OutputBufferId, long)260%20%225511
updateMetadataResults(TaskId, MetadataUpdates)240%20%225511
lambda$new$2(LocationFactory, NodeInfo, SqlTaskExecutionFactory, ExchangeClientSupplier, long, SpoolingOutputBufferFactory, TaskId)240%n/a114411
updateStats()230%n/a117711
createQueryContext(QueryId, LocalMemoryManager, LocalSpillManager, GcMonitor, DataSize, DataSize, DataSize, DataSize, DataSize)210%n/a113311
getTaskInfo(TaskId, TaskState)200%n/a115511
getTaskStatus(TaskId, TaskState)200%n/a115511
start()190%n/a113311
lambda$start$4()170%n/a119911
abortTaskResults(TaskId, OutputBuffers.OutputBufferId)160%n/a113311
removeRemoteSource(TaskId, TaskId)160%n/a114411
getTaskInfo(TaskId)150%n/a114411
getTaskStatus(TaskId)150%n/a114411
lambda$updateMemoryPoolAssignments$3(MemoryPoolAssignment)130%n/a111111
addStateChangeListener(TaskId, StateMachine.StateChangeListener)120%n/a113311
lambda$new$0(LocalMemoryManager, LocalSpillManager, GcMonitor, DataSize, DataSize, DataSize, DataSize, DataSize, QueryId)120%n/a111111
getTaskInstanceId(TaskId)110%n/a113311
getOutputBufferInfo(TaskId)110%n/a112211
cancelTask(TaskId)110%n/a112211
abortTask(TaskId)110%n/a112211
lambda$start$5()90%n/a115511
getAllTaskInfo()80%n/a111111
lambda$updateStats$6(SqlTask)80%20%221111
lambda$null$1(SqlTask)70%n/a112211
getAllTasks()60%n/a111111
getTask(TaskId)60%n/a111111
getQueryContext(QueryId)60%n/a111111
lambda$updateStats$7(SqlTaskIoStats, SqlTask)50%n/a111111
static {...}40%n/a111111
getIoStats()30%n/a111111
getTaskNotificationExecutor()30%n/a111111
getFailedTasks()30%n/a111111