SqlTaskManager(LocalExecutionPlanner, LocationFactory, TaskExecutor, SplitMonitor, NodeInfo, LocalMemoryManager, JsonCodec, TaskManagementExecutor, TaskManagerConfig, NodeMemoryConfig, LocalSpillManager, ExchangeClientSupplier, NodeSpillConfig, GcMonitor, BlockEncodingSerde, OrderingCompiler, FragmentResultCacheManager, ObjectMapper, SpoolingOutputBufferFactory) |  | 0% | | n/a | 1 | 1 | 26 | 26 | 1 | 1 |
updateTask(Session, TaskId, Optional, List, OutputBuffers, Optional) |  | 0% |  | 0% | 3 | 3 | 23 | 23 | 1 | 1 |
updateMemoryPoolAssignments(MemoryPoolAssignmentsRequest) |  | 0% |  | 0% | 5 | 5 | 16 | 16 | 1 | 1 |
failAbandonedTasks() |  | 0% |  | 0% | 5 | 5 | 16 | 16 | 1 | 1 |
removeOldTasks() |  | 0% |  | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
close() |  | 0% |  | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
getTaskResults(TaskId, OutputBuffers.OutputBufferId, long, long) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
acknowledgeTaskResults(TaskId, OutputBuffers.OutputBufferId, long) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
updateMetadataResults(TaskId, MetadataUpdates) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
lambda$new$2(LocationFactory, NodeInfo, SqlTaskExecutionFactory, ExchangeClientSupplier, long, SpoolingOutputBufferFactory, TaskId) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
updateStats() |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
createQueryContext(QueryId, LocalMemoryManager, LocalSpillManager, GcMonitor, DataSize, DataSize, DataSize, DataSize, DataSize) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getTaskInfo(TaskId, TaskState) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
getTaskStatus(TaskId, TaskState) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
start() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$start$4() |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
abortTaskResults(TaskId, OutputBuffers.OutputBufferId) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
removeRemoteSource(TaskId, TaskId) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
getTaskInfo(TaskId) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
getTaskStatus(TaskId) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
lambda$updateMemoryPoolAssignments$3(MemoryPoolAssignment) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
addStateChangeListener(TaskId, StateMachine.StateChangeListener) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$new$0(LocalMemoryManager, LocalSpillManager, GcMonitor, DataSize, DataSize, DataSize, DataSize, DataSize, QueryId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTaskInstanceId(TaskId) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getOutputBufferInfo(TaskId) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
cancelTask(TaskId) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
abortTask(TaskId) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$start$5() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
getAllTaskInfo() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$updateStats$6(SqlTask) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$null$1(SqlTask) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getAllTasks() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTask(TaskId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getQueryContext(QueryId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$updateStats$7(SqlTaskIoStats, SqlTask) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getIoStats() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTaskNotificationExecutor() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getFailedTasks() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |