| computeFragmentHosts() |   | 57% | | 47% | 39 | 52 | 59 | 141 | 0 | 1 |
| updateFragmentExecStatus(TReportExecStatusParams) | | 0% | | 0% | 23 | 23 | 64 | 64 | 1 | 1 |
| waitPipelineRpc(List, long, String) | | 27% | | 26% | 11 | 13 | 44 | 65 | 0 | 1 |
| Coordinator(Long, TUniqueId, DescriptorTable, List, List, String, boolean, boolean) | | 0% | | 0% | 2 | 2 | 55 | 55 | 1 | 1 |
| assignScanRanges(PlanFragmentId, int, Coordinator.FragmentExecParams, Map, Map, Map, boolean) | | 61% | | 52% | 17 | 26 | 33 | 84 | 0 | 1 |
| setDestination(Coordinator.FragmentExecParams, int, int) | | 0% | | 0% | 7 | 7 | 30 | 30 | 1 | 1 |
| updateLoadCounters(Map) | | 0% | | 0% | 7 | 7 | 27 | 27 | 1 | 1 |
| execInternal() | | 60% | | 50% | 10 | 14 | 20 | 55 | 0 | 1 |
| computeScanRangeAssignment() | | 56% | | 50% | 16 | 21 | 21 | 50 | 0 | 1 |
| computeFragmentExecParams() | | 76% | | 57% | 13 | 22 | 18 | 74 | 0 | 1 |
| computeMultiCastFragmentParams() | | 70% | | 50% | 13 | 19 | 18 | 58 | 0 | 1 |
| cancel(Status) | | 0% | | 0% | 6 | 6 | 19 | 19 | 1 | 1 |
| sendPipelineCtx() | | 85% | | 66% | 12 | 25 | 14 | 98 | 0 | 1 |
| shouldCancel(List) | | 47% | | 57% | 5 | 8 | 11 | 24 | 0 | 1 |
| getNext() | | 50% | | 38% | 9 | 10 | 13 | 30 | 0 | 1 |
| selectBackendsByRoundRobin(TScanRangeLocations, Map, Map, Reference, boolean) | | 19% | | 20% | 5 | 6 | 14 | 18 | 0 | 1 |
| getStreamLoadPlan() | | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
| join(int) | | 0% | | 0% | 5 | 5 | 17 | 17 | 1 | 1 |
| getFragmentInstanceInfos() | | 0% | | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
| getBeToInstancesNum() | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| updateScanRangeNumByScanRange(TScanRangeParams) | | 42% | | 28% | 7 | 8 | 8 | 18 | 0 | 1 |
| checkBackendState() | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| getInvolvedBackends() | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| containsUnionNode(PlanNode) | | 0% | | 0% | 5 | 5 | 9 | 9 | 1 | 1 |
| containsIntersectNode(PlanNode) | | 0% | | 0% | 5 | 5 | 9 | 9 | 1 | 1 |
| containsExceptNode(PlanNode) | | 0% | | 0% | 5 | 5 | 9 | 9 | 1 | 1 |
| containsSetOperationNode(PlanNode) | | 0% | | 0% | 5 | 5 | 9 | 9 | 1 | 1 |
| updateErrorTabletInfos(List) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| clearExportStatus() | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
| cancelRemoteFragmentsAsync(Status) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| toArrowFlightHost(TNetworkAddress) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| setTimeout(int) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| isDone() | | 0% | | 0% | 4 | 4 | 3 | 3 | 1 | 1 |
| updateStatus(Status) | | 38% | | 25% | 4 | 5 | 6 | 11 | 0 | 1 |
| cancelInternal(Status) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| getGroupCommitBackend(Map) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| updateCommitInfos(List) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| cancelLatch() | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| updateExportFiles(List) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| lambda$computeFragmentExecParams$12(Map, Coordinator.FragmentExecParams, Coordinator.FInstanceExecParam) | | 69% | | 50% | 1 | 2 | 3 | 12 | 0 | 1 |
| prepare() | | 91% | | 66% | 5 | 10 | 2 | 30 | 0 | 1 |
| setFromUserProperty(ConnectContext) | | 63% | | 50% | 2 | 3 | 3 | 10 | 0 | 1 |
| Coordinator(ConnectContext, Planner) | | 95% | | 66% | 2 | 4 | 2 | 65 | 0 | 1 |
| updateDeltas(List) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| lambda$updateCommitInfos$11(Map, TTabletCommitInfo) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| close() | | 73% | | 83% | 1 | 4 | 4 | 12 | 0 | 1 |
| exec() | | 88% | | 62% | 3 | 5 | 2 | 20 | 0 | 1 |
| initQueryOptions(ConnectContext) | | 80% | | 50% | 2 | 3 | 1 | 9 | 0 | 1 |
| isTimeout() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$assignScanRanges$20(int, ScanNode) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| sortScanNodes() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| toBrpcHost(TNetworkAddress) | | 74% | | 50% | 2 | 3 | 2 | 7 | 0 | 1 |
| sortScanRangeLocations(List) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$computeMultiCastFragmentParams$13(Map, List, Coordinator.FInstanceExecParam) | | 89% | | 100% | 0 | 2 | 2 | 12 | 0 | 1 |
| lambda$sendPipelineCtx$2(AtomicLong, Coordinator.PipelineExecContexts) | | 53% | | n/a | 0 | 1 | 2 | 5 | 0 | 1 |
| setQueryType(TQueryType) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setExecMemoryLimit(long) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setLoadMemLimit(long) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setLoadZeroTolerance(boolean) | | 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 |
| setProfileLevel(int) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| toRpcHost(TNetworkAddress) | | 79% | | 50% | 1 | 2 | 1 | 6 | 0 | 1 |
| shouldQueue() | | 89% | | 58% | 5 | 7 | 2 | 10 | 0 | 1 |
| setGroupCommitBe(Backend) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getNumReceivedRows() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setQueryId(TUniqueId) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setTxnId(long) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getTWorkloadGroups() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getConnectContext() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getQueryId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getScanRangeNum() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getExecStatus() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getDeltaUrls() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getLoadCounters() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getTrackingUrl() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getFirstErrorMsg() | | 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 |
| getCommitInfos() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getErrorTabletInfos() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getExportFiles() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getQueueToken() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getFragments() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| isColocateFragment(PlanFragment, PlanNode) | | 93% | | 75% | 2 | 5 | 1 | 9 | 0 | 1 |
| setIsProfileSafeStmt(boolean) | | 85% | | 50% | 2 | 3 | 0 | 2 | 0 | 1 |
| findMaxParallelFragmentIndex(PlanFragment) | | 98% | | 83% | 1 | 4 | 0 | 13 | 0 | 1 |
| lambda$findMaxParallelFragmentIndex$15(PlanFragment) | | 87% | | 50% | 1 | 2 | 0 | 1 | 0 | 1 |
| computeScanRangeAssignmentByColocate(OlapScanNode, Map, Map, boolean) | | 100% | | 75% | 2 | 5 | 0 | 24 | 0 | 1 |
| assignRuntimeFilterAddr() | | 100% | | 100% | 0 | 5 | 0 | 18 | 0 | 1 |
| selectBackendsByRoundRobin(List, Map, Map, Reference) | | 100% | | 90% | 1 | 6 | 0 | 18 | 0 | 1 |
| computeScanRangeAssignmentByScheduler(ScanNode, List, Coordinator.FragmentScanRangeAssignment, Map, Map, boolean) | | 100% | | 100% | 0 | 2 | 0 | 15 | 0 | 1 |
| getReplicaNumPerHostForOlapTable() | | 100% | | 100% | 0 | 5 | 0 | 12 | 0 | 1 |
| traceInstance() | | 100% | | 75% | 2 | 5 | 0 | 15 | 0 | 1 |
| getExecHostPortForFragmentIDAndBucketSeq(TScanRangeLocations, PlanFragmentId, Integer, Map, Map, boolean) | | 100% | | n/a | 0 | 1 | 0 | 7 | 0 | 1 |
| findLeftmostNode(PlanNode) | | 100% | | 100% | 0 | 3 | 0 | 6 | 0 | 1 |
| findOrInsert(Map, Integer, ArrayList) | | 100% | | 100% | 0 | 2 | 0 | 5 | 0 | 1 |
| static {...} | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| findOrInsert(Map, Object, Object) | | 100% | | 100% | 0 | 2 | 0 | 5 | 0 | 1 |
| computeColocateJoinInstanceParam(PlanFragmentId, int, Coordinator.FragmentExecParams, boolean) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| isQueryCancelled() | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
| updateProfileIfPresent(Consumer) | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
| lambda$computeFragmentHosts$14(Integer, ScanNode) | | 100% | | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
| Coordinator(ConnectContext, Planner, StatsErrorEstimator) | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
| processFragmentAssignmentAndParams() | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| lambda$sendPipelineCtx$8(List, SummaryProfile) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$sendPipelineCtx$5(List, SummaryProfile) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$sendPipelineCtx$3(AtomicLong, SummaryProfile) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| setTWorkloadGroups(List) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| lock() | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| unlock() | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| lambda$assignRuntimeFilterAddr$16(RuntimeFilterId) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$sendPipelineCtx$10(Map, SummaryProfile) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$sendPipelineCtx$7(Map, SummaryProfile) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getExecutionProfile() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getJobId() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getQueryOptions() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getFragmentExecParamsMap() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$computeScanRangeAssignment$18(ScanNode) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$assignRuntimeFilterAddr$17(Coordinator.FInstanceExecParam) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$sendPipelineCtx$9(SummaryProfile) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$sendPipelineCtx$6(SummaryProfile) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$sendPipelineCtx$4(SummaryProfile) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$execInternal$1(SummaryProfile) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$exec$0(WorkloadGroup) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$computeScanRangeAssignment$19(PlanFragmentId) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |