LocalDispatchQuery(QueryStateMachine, QueryMonitor, ListenableFuture, ClusterSizeMonitor, Executor, Consumer, Consumer, boolean, QueryPrerequisites) |  | 0% | | n/a | 1 | 1 | 16 | 16 | 1 | 1 |
getDispatchInfo() |  | 0% |  | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
startWaitingForPrerequisites() |  | 0% |  | 0% | 2 | 2 | 17 | 17 | 1 | 1 |
lambda$startExecution$8(boolean, QueryExecution) |  | 0% |  | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
cancel() |  | 0% |  | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
waitForMinimumCoordinatorSidecarsAndWorkers() |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
lambda$startWaitingForPrerequisites$2(CompletableFuture, QueryState) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
fail(Throwable) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
setResourceGroupQueryLimits(ResourceGroupQueryLimits) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
queueQuery() |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
lambda$new$0(QueryStateMachine, QueryMonitor, Throwable) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
lambda$waitForMinimumCoordinatorSidecarsAndWorkers$5() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getTotalMemoryReservationInBytes() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getUserMemoryReservationInBytes() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getBasicQueryInfo() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$startWaitingForPrerequisites$3(Object, Throwable) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
lambda$new$1(QueryState) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
startExecution(QueryExecution, boolean) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getTotalCpuTime() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
startWaitingForResources() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
tryGetQueryExecution() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$getDispatchInfo$9() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$waitForMinimumCoordinatorSidecarsAndWorkers$7(Throwable) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getErrorCode() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getTotalCpuTime$10() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isDone() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
addStateChangeListener(StateMachine.StateChangeListener) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getResourceGroupQueryLimits() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getBasicQueryInfo$11() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$null$4(boolean, QueryExecution) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
recordHeartbeat() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getLastHeartbeatInMillis() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getDispatchedFuture() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getQueryId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCreateTimeInMillis() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getExecutionStartTimeInMillis() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getEndTimeInMillis() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getRunningTaskCount() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getSession() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
pruneExpiredQueryInfo() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
pruneFinishedQueryInfo() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$null$6(Throwable) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isRetry() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |