CoordinatorContext(NereidsCoordinator, long, List, List, List, TUniqueId, TQueryOptions, TQueryGlobals, TDescriptorTable, ExecutionProfile) |  | 0% | | n/a | 1 | 1 | 29 | 29 | 1 | 1 |
buildForLoad(NereidsCoordinator, long, TUniqueId, List, List, List, DescriptorTable, String, boolean, boolean) |  | 0% | | n/a | 1 | 1 | 15 | 15 | 1 | 1 |
getBackends() |  | 0% |  | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
getScanRangeNum() |   | 59% |   | 56% | 4 | 9 | 9 | 23 | 0 | 1 |
updateStatusIfOk(Status) |  | 0% |  | 0% | 6 | 6 | 11 | 11 | 1 | 1 |
getInstanceIds() |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
computeScanRangeNumByScanRange(TScanRangeParams) |   | 43% |   | 28% | 7 | 8 | 8 | 19 | 0 | 1 |
computeDirectConnectCoordinator() |  | 0% |  | 0% | 4 | 4 | 4 | 4 | 1 | 1 |
setOptionsFromUserProperty(ConnectContext, TQueryOptions) |   | 64% |   | 50% | 2 | 3 | 3 | 10 | 0 | 1 |
isEos() |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
updateProfileIfPresent(Consumer) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
readCloneStatus() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
initQueryOptions(ConnectContext) |   | 81% |   | 50% | 2 | 3 | 1 | 10 | 0 | 1 |
setQueueInfo(QueryQueue, QueueToken) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
twoPhaseExecution() |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
initQueryGlobals(ConnectContext) |   | 88% |   | 50% | 1 | 2 | 1 | 9 | 0 | 1 |
cancelSchedule(Status) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$buildForLoad$1(PlanFragment) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
CoordinatorContext(NereidsCoordinator, ConnectContext, List, List, List, List, List, ExecutionProfile, TQueryGlobals, TQueryOptions, TDescriptorTable) |   | 96% |   | 50% | 2 | 3 | 0 | 28 | 0 | 1 |
setWorkloadGroups(List) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
asLoadProcessor() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
asQueryProcessor() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getQueueToken() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getQueryQueue() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getWorkloadGroups() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
withLock(Runnable) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
withLock(Callable) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getJobProcessor() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
buildForSql(NereidsPlanner, NereidsCoordinator) |  | 100% | | n/a | 0 | 1 | 0 | 13 | 0 | 1 |
computeInstanceNum() |  | 100% | | n/a | 0 | 1 | 0 | 5 | 0 | 1 |
computeTimeoutDeadline() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$computeInstanceNum$2(PipelineDistributedPlan) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$buildForSql$0(PlanFragment) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
setJobProcessor(JobProcessor) |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
static {...} |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |