| enqueue(ConnectContext) |  | 0% | | 0% | 7 | 7 | 19 | 19 | 1 | 1 |
| setForArrowFlight(CoordinatorContext, PipelineDistributedPlan) | | 0% | | 0% | 8 | 8 | 18 | 18 | 1 | 1 |
| cancel(Status) | | 0% | | 0% | 5 | 5 | 16 | 16 | 1 | 1 |
| close() | | 0% | | 0% | 4 | 4 | 12 | 12 | 1 | 1 |
| getBeToInstancesNum() | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| NereidsCoordinator(Long, TUniqueId, DescriptorTable, List, List, List, String, boolean, boolean) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| getFragmentInstanceInfos() | | 0% | | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
| shouldQueue(ConnectContext) | | 0% | | 0% | 7 | 7 | 9 | 9 | 1 | 1 |
| exec() | | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
| setForBroker(CoordinatorContext, PipelineDistributedPlan) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| setTimeout(int) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| setIsProfileSafeStmt(boolean) | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
| isTimeout() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| getJobId() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| buildJobProcessor(CoordinatorContext) |  | 50% | | 25% | 2 | 3 | 1 | 4 | 0 | 1 |
| processTopSink(CoordinatorContext, PipelineDistributedPlan) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| getInvolvedBackends() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setQueryType(TQueryType) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setLoadZeroTolerance(boolean) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getQueueToken() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setTxnId(long) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setMemTableOnSinkNode(boolean) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setBatchSize(int) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setLoadMemLimit(long) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setExecMemoryLimit(long) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| cancelInternal(Status) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| join(int) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| updateFragmentExecStatus(TReportExecStatusParams) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getLoadCounters() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getDeltaUrls() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getCommitInfos() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getExportFiles() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getTxnId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getLabel() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getTrackingUrl() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getErrorTabletInfos() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$cancelInternal$0(Status) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setTWorkloadGroups(List) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| isQueryCancelled() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getNext() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| isEos() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getNumReceivedRows() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| isDone() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| asQueryProcessor() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getJobProcessor() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| asLoadProcessor() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getTWorkloadGroups() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getQueryId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getQueryOptions() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getExecStatus() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getConnectContext() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getFragments() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getExecutionProfile() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| NereidsCoordinator(ConnectContext, Analyzer, NereidsPlanner, StatsErrorEstimator) | | 97% | | 50% | 2 | 3 | 0 | 7 | 0 | 1 |
| getScanRangeNum() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| static {...} | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |