| waitPipelineRpc(List, long, String) |   | 36% | | 47% | 9 | 13 | 37 | 65 | 0 | 1 |
| computeFragmentHosts() | | 80% | | 72% | 24 | 52 | 23 | 141 | 0 | 1 |
| updateFragmentExecStatus(TReportExecStatusParams) | | 54% | | 61% | 13 | 22 | 25 | 61 | 0 | 1 |
| execInternal() | | 65% | | 46% | 10 | 14 | 17 | 55 | 0 | 1 |
| computeMultiCastFragmentParams() | | 70% | | 58% | 11 | 19 | 19 | 58 | 0 | 1 |
| prepare() | | 50% | | 50% | 6 | 10 | 15 | 30 | 0 | 1 |
| computeScanRangeAssignment() | | 67% | | 67% | 10 | 21 | 18 | 50 | 0 | 1 |
| shouldCancel(List) | | 47% | | 57% | 5 | 8 | 11 | 24 | 0 | 1 |
| traceInstance() | | 6% | | 12% | 4 | 5 | 13 | 15 | 0 | 1 |
| selectBackendsByRoundRobin(TScanRangeLocations, Map, Map, Reference, boolean) | | 19% | | 20% | 5 | 6 | 14 | 18 | 0 | 1 |
| lambda$computeMultiCastFragmentParams$13(Map, List, Coordinator.FInstanceExecParam) | | 0% | | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
| computeFragmentExecParams() | | 88% | | 83% | 7 | 22 | 7 | 74 | 0 | 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 |
| cancel(Status) | | 62% | | 60% | 3 | 6 | 5 | 19 | 0 | 1 |
| getNext() | | 78% | | 66% | 6 | 10 | 5 | 30 | 0 | 1 |
| updateErrorTabletInfos(List) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| clearExportStatus() | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
| toArrowFlightHost(TNetworkAddress) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| setTimeout(int) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| updateScanRangeNumByScanRange(TScanRangeParams) | | 68% | | 57% | 5 | 8 | 4 | 18 | 0 | 1 |
| checkBackendState() | | 45% | | 75% | 1 | 3 | 3 | 7 | 0 | 1 |
| getGroupCommitBackend(Map) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| sendPipelineCtx() | | 96% | | 85% | 7 | 25 | 3 | 98 | 0 | 1 |
| updateExportFiles(List) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| selectBackendsByRoundRobin(List, Map, Map, Reference) | | 87% | | 50% | 3 | 6 | 1 | 18 | 0 | 1 |
| setFromUserProperty(ConnectContext) | | 63% | | 50% | 2 | 3 | 3 | 10 | 0 | 1 |
| Coordinator(ConnectContext, Planner) | | 95% | | 66% | 2 | 4 | 2 | 64 | 0 | 1 |
| updateDeltas(List) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| join(int) | | 77% | | 62% | 3 | 5 | 4 | 17 | 0 | 1 |
| isDone() | | 52% | | 33% | 3 | 4 | 1 | 3 | 0 | 1 |
| close() | | 73% | | 100% | 0 | 4 | 4 | 12 | 0 | 1 |
| updateLoadCounters(Map) | | 92% | | 50% | 6 | 7 | 3 | 27 | 0 | 1 |
| exec() | | 88% | | 62% | 3 | 5 | 2 | 20 | 0 | 1 |
| isTimeout() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| sortScanNodes() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| initQueryOptions(ConnectContext) | | 85% | | 75% | 1 | 3 | 1 | 9 | 0 | 1 |
| toBrpcHost(TNetworkAddress) | | 74% | | 50% | 2 | 3 | 2 | 7 | 0 | 1 |
| sortScanRangeLocations(List) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$computeFragmentExecParams$12(Map, Coordinator.FragmentExecParams, 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 |
| setExecMemoryLimit(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 |
| 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 |
| updateStatus(Status) | | 88% | | 62% | 2 | 5 | 1 | 11 | 0 | 1 |
| getNumReceivedRows() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setQueryId(TUniqueId) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getConnectContext() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getJobId() | | 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 |
| getDeltaUrls() | | 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 |
| getExportFiles() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getFragmentExecParamsMap() | | 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 |
| assignScanRanges(PlanFragmentId, int, Coordinator.FragmentExecParams, Map, Map, Map, boolean) | | 99% | | 88% | 6 | 26 | 0 | 84 | 0 | 1 |
| findMaxParallelFragmentIndex(PlanFragment) | | 98% | | 83% | 1 | 4 | 0 | 13 | 0 | 1 |
| getFragmentInstanceInfos() | | 97% | | 83% | 1 | 4 | 1 | 11 | 0 | 1 |
| Coordinator(Long, TUniqueId, DescriptorTable, List, List, String, boolean, boolean) | | 100% | | 100% | 0 | 2 | 0 | 55 | 0 | 1 |
| setDestination(Coordinator.FragmentExecParams, int, int) | | 100% | | 100% | 0 | 7 | 0 | 30 | 0 | 1 |
| computeScanRangeAssignmentByColocate(OlapScanNode, Map, Map, boolean) | | 100% | | 100% | 0 | 5 | 0 | 24 | 0 | 1 |
| assignRuntimeFilterAddr() | | 100% | | 100% | 0 | 5 | 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 |
| getStreamLoadPlan() | | 100% | | n/a | 0 | 1 | 0 | 9 | 0 | 1 |
| getExecHostPortForFragmentIDAndBucketSeq(TScanRangeLocations, PlanFragmentId, Integer, Map, Map, boolean) | | 100% | | n/a | 0 | 1 | 0 | 7 | 0 | 1 |
| getBeToInstancesNum() | | 100% | | 100% | 0 | 2 | 0 | 6 | 0 | 1 |
| cancelRemoteFragmentsAsync(Status) | | 100% | | 100% | 0 | 2 | 0 | 6 | 0 | 1 |
| findLeftmostNode(PlanNode) | | 100% | | 100% | 0 | 3 | 0 | 6 | 0 | 1 |
| cancelInternal(Status) | | 100% | | 100% | 0 | 2 | 0 | 6 | 0 | 1 |
| updateCommitInfos(List) | | 100% | | n/a | 0 | 1 | 0 | 6 | 0 | 1 |
| cancelLatch() | | 100% | | 100% | 0 | 3 | 0 | 5 | 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 |
| setIsProfileSafeStmt(boolean) | | 100% | | 100% | 0 | 3 | 0 | 2 | 0 | 1 |
| computeColocateJoinInstanceParam(PlanFragmentId, int, Coordinator.FragmentExecParams, boolean) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| lambda$updateCommitInfos$11(Map, TTabletCommitInfo) | | 100% | | n/a | 0 | 1 | 0 | 1 | 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 |
| lambda$assignScanRanges$20(int, ScanNode) | | 100% | | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
| Coordinator(ConnectContext, Planner, StatsErrorEstimator) | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
| lambda$findMaxParallelFragmentIndex$15(PlanFragment) | | 100% | | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
| processFragmentAssignmentAndParams() | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| setQueryType(TQueryType) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| setLoadMemLimit(long) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| setLoadZeroTolerance(boolean) | | 100% | | n/a | 0 | 1 | 0 | 2 | 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 |
| setGroupCommitBe(Backend) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| setTWorkloadGroups(List) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| setTxnId(long) | | 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 |
| getTWorkloadGroups() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getExecutionProfile() | | 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 |
| getLoadCounters() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getTrackingUrl() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getCommitInfos() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getQueueToken() | | 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 |