| getFragmentInstanceInfos() |  | 0% | | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
| getBeToInstancesNum() | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| recordLoadSinkCoordinator(CoordinatorContext, PipelineDistributedPlan) |  | 35% | | 33% | 5 | 7 | 9 | 14 | 0 | 1 |
| setForBroker(CoordinatorContext, PipelineDistributedPlan) | | 19% | | 25% | 2 | 3 | 6 | 9 | 0 | 1 |
| setTimeout(int) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| enqueue(ConnectContext) | | 84% | | 60% | 4 | 6 | 4 | 22 | 0 | 1 |
| isTimeout() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| close() | | 79% | | 83% | 1 | 4 | 4 | 12 | 0 | 1 |
| getInvolvedBackends() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setMemTableOnSinkNode(boolean) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setBatchSize(int) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setExecMemoryLimit(long) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| cancel(Status) | | 91% | | 75% | 2 | 5 | 1 | 20 | 0 | 1 |
| exec() | | 90% | | 75% | 1 | 3 | 1 | 14 | 0 | 1 |
| updateFragmentExecStatus(TReportExecStatusParams) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getLoadCounters() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getDeltaUrls() | | 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 |
| getErrorTabletInfos() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setForArrowFlight(CoordinatorContext, PipelineDistributedPlan) | | 93% | | 81% | 3 | 9 | 1 | 20 | 0 | 1 |
| getNumReceivedRows() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| shouldCancel(List) | | 95% | | 83% | 2 | 7 | 2 | 19 | 0 | 1 |
| shouldQueue(ConnectContext) | | 89% | | 58% | 5 | 7 | 2 | 9 | 0 | 1 |
| asQueryProcessor() | | 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 |
| getConnectContext() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getStreamLoadPlan() | | 93% | | 50% | 3 | 4 | 0 | 7 | 0 | 1 |
| setIsProfileSafeStmt(boolean) | | 87% | | 50% | 2 | 3 | 0 | 2 | 0 | 1 |
| Coordinator(ConnectContext, NereidsPlanner, StatsErrorEstimator) | | 97% | | 62% | 3 | 5 | 0 | 11 | 0 | 1 |
| Coordinator(Long, TUniqueId, DescriptorTable, List, List, List, String, boolean, boolean) | | 97% | | 50% | 2 | 3 | 0 | 9 | 0 | 1 |
| Coordinator(ConnectContext, NereidsPlanner, StatsErrorEstimator, long) | | 96% | | 50% | 2 | 3 | 0 | 8 | 0 | 1 |
| syncLocalShufflePlannerOption() | | 96% | | 50% | 4 | 5 | 0 | 4 | 0 | 1 |
| setForInsert(long) | | 100% | | n/a | 0 | 1 | 0 | 7 | 0 | 1 |
| preferTerminalReason(UserException) | | 100% | | 100% | 0 | 2 | 0 | 4 | 0 | 1 |
| getJobId() | | 100% | | 100% | 0 | 2 | 0 | 4 | 0 | 1 |
| processTopSink(CoordinatorContext, PipelineDistributedPlan) | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| getScanBackendIds() | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
| static {...} | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| getDispatchedBackendIdsForAudit() | | 100% | | 100% | 0 | 2 | 0 | 2 | 0 | 1 |
| setForQuery() | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
| mustOutliveDispatch() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| setQueryType(TQueryType) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| setLoadZeroTolerance(boolean) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| getScanRangeNum() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getQueueToken() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| setTxnId(long) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| setLoadMemLimit(long) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| cancelInternal(Status) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| join(int) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getCommitInfos() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getTrackingUrl() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getFirstErrorMsg() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$cancelInternal$1(Status) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| setTWorkloadGroups(List) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| isQueryCancelled() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getNext() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| isEos() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| isDone() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getJobProcessor() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getQueryStatus() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getQueryId() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getQueryOptions() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getExecStatus() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getFragments() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getExecutionProfile() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$getScanBackendIds$0(ScanNode) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getCoordinatorContext() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$enqueue$2(WorkloadGroup) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |