createTaskStatus(SqlTask.TaskHolder) |  | 0% |  | 0% | 5 | 5 | 54 | 54 | 1 | 1 |
SqlTask(TaskId, URI, String, QueryContext, SqlTaskExecutionFactory, ExchangeClientSupplier, ExecutorService, long, SpoolingOutputBufferFactory) |  | 0% |  | 0% | 2 | 2 | 21 | 21 | 1 | 1 |
updateTask(Session, Optional, List, OutputBuffers, Optional) |  | 0% |  | 0% | 4 | 4 | 24 | 24 | 1 | 1 |
getMetadataUpdateRequests(SqlTask.TaskHolder) |  | 0% |  | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
getTaskStats(SqlTask.TaskHolder) |  | 0% |  | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
createTaskInfo(SqlTask.TaskHolder) |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
abortTaskResults(OutputBuffers.OutputBufferId) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
removeRemoteSource(TaskId) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
getTaskInfo() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getTaskStatus() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getTaskStatus(TaskState) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
getTaskInfo(TaskState) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
getTaskResults(OutputBuffers.OutputBufferId, long, long) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
createSqlTask(TaskId, URI, String, QueryContext, SqlTaskExecutionFactory, ExchangeClientSupplier, ExecutorService, Function, long, CounterStat, SpoolingOutputBufferFactory) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
initialize(Function, CounterStat) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
getNoMoreSplits(SqlTask.TaskHolder) |  | 0% |  | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
getTaskContext() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
acknowledgeTaskResults(OutputBuffers.OutputBufferId, long) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
failed(Throwable) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getTaskMetadataContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getIoStats() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
cancel() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
abort() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
recordHeartbeat() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
addStateChangeListener(StateMachine.StateChangeListener) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$new$0(QueryContext, TaskId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isOutputBufferOverutilized() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTaskId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTaskInstanceId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTaskState() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTaskCreatedTime() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getOutputBufferInfo() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
toString() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$removeRemoteSource$3(TaskId, ExchangeClient) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getQueryContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getTaskInfo$2(TaskState) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getTaskStatus$1(TaskState) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |