| computeFragmentHosts() |  | 0% | | 0% | 57 | 57 | 154 | 154 | 1 | 1 |
| sendPipelineCtx() | | 0% | | 0% | 28 | 28 | 109 | 109 | 1 | 1 |
| assignScanRanges(PlanFragmentId, int, Coordinator.FragmentExecParams, Map, Map, Map, boolean) | | 0% | | 0% | 26 | 26 | 84 | 84 | 1 | 1 |
| computeFragmentExecParams() | | 0% | | 0% | 22 | 22 | 74 | 74 | 1 | 1 |
| waitPipelineRpc(List, long, String) | | 0% | | 0% | 13 | 13 | 65 | 65 | 1 | 1 |
| updateFragmentExecStatus(TReportExecStatusParams) | | 0% | | 0% | 28 | 28 | 72 | 72 | 1 | 1 |
| computeMultiCastFragmentParams() | | 0% | | 0% | 19 | 19 | 58 | 58 | 1 | 1 |
| execInternal() | | 0% | | 0% | 14 | 14 | 54 | 54 | 1 | 1 |
| computeScanRangeAssignment() | | 0% | | 0% | 21 | 21 | 50 | 50 | 1 | 1 |
| prepare() | | 0% | | 0% | 13 | 13 | 43 | 43 | 1 | 1 |
| setDestination(Coordinator.FragmentExecParams, int, int) | | 0% | | 0% | 7 | 7 | 30 | 30 | 1 | 1 |
| shouldCancel(List) | | 0% | | 0% | 8 | 8 | 24 | 24 | 1 | 1 |
| getNext() | | 0% | | 0% | 10 | 10 | 30 | 30 | 1 | 1 |
| computeScanRangeAssignmentByColocate(OlapScanNode, Map, Map, boolean) | | 0% | | 0% | 5 | 5 | 24 | 24 | 1 | 1 |
| assignRuntimeFilterAddr() | | 0% | | 0% | 5 | 5 | 18 | 18 | 1 | 1 |
| updateLoadCounters(Map) | | 0% | | 0% | 7 | 7 | 27 | 27 | 1 | 1 |
| assignAdaptiveRandomBucketForFragment(Collection) | | 0% | | 0% | 6 | 6 | 32 | 32 | 1 | 1 |
| exec() | | 0% | | 0% | 6 | 6 | 26 | 26 | 1 | 1 |
| computeScanRangeAssignmentByScheduler(ScanNode, List, Coordinator.FragmentScanRangeAssignment, Map, Map, boolean) | | 0% | | 0% | 2 | 2 | 15 | 15 | 1 | 1 |
| cancel(Status) | | 0% | | 0% | 6 | 6 | 23 | 23 | 1 | 1 |
| getAdaptiveRandomBucketSinkContext(long) | | 0% | | 0% | 7 | 7 | 19 | 19 | 1 | 1 |
| getReplicaNumPerHostForOlapTable() | | 0% | | 0% | 5 | 5 | 12 | 12 | 1 | 1 |
| traceInstance() | | 0% | | 0% | 5 | 5 | 15 | 15 | 1 | 1 |
| updateScanRangeNumByScanRange(TScanRangeParams) | | 0% | | 0% | 8 | 8 | 18 | 18 | 1 | 1 |
| selectBackendsByRoundRobin(TScanRangeLocations, Map, Map, Reference, boolean, boolean) |  | 30% | | 20% | 5 | 6 | 15 | 22 | 0 | 1 |
| lambda$computeFragmentExecParams$13(Map, Coordinator.FragmentExecParams, Coordinator.FInstanceExecParam) | | 0% | | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
| lambda$computeMultiCastFragmentParams$14(Map, List, Coordinator.FInstanceExecParam) | | 0% | | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
| getStreamLoadPlan() | | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
| findMaxParallelFragmentIndex(PlanFragment) | | 0% | | 0% | 5 | 5 | 14 | 14 | 1 | 1 |
| join(int) | | 0% | | 0% | 5 | 5 | 17 | 17 | 1 | 1 |
| getNeededAiResources() | | 0% | | 0% | 5 | 5 | 10 | 10 | 1 | 1 |
| getFragmentInstanceInfos() | | 0% | | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
| getExecHostPortForFragmentIDAndBucketSeq(TScanRangeLocations, PlanFragmentId, Integer, Map, Map, boolean) | | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| shouldQueue() | | 0% | | 0% | 7 | 7 | 10 | 10 | 1 | 1 |
| close() | | 0% | | 0% | 4 | 4 | 12 | 12 | 1 | 1 |
| updateStatus(Status) | | 0% | | 0% | 5 | 5 | 11 | 11 | 1 | 1 |
| getBeToInstancesNum() | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| isColocateFragment(PlanFragment, PlanNode) | | 0% | | 0% | 5 | 5 | 9 | 9 | 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 |
| checkBackendState() | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| updateErrorTabletInfos(List) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| cancelRemoteFragmentsAsync(Status) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| toBrpcHost(TNetworkAddress) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| toArrowFlightHost(TNetworkAddress) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| toRpcHost(TNetworkAddress) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| chooseHostByCurrentBackendSelection(Map) | | 70% | | 70% | 3 | 6 | 6 | 20 | 0 | 1 |
| setTimeout(int) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| findLeftmostNode(PlanNode) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| isDone() | | 0% | | 0% | 4 | 4 | 3 | 3 | 1 | 1 |
| getScanBackendIds() | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 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 |
| findOrInsert(Map, Integer, ArrayList) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| lambda$applyBackendSelection$21(TScanRangeLocation) | | 0% | | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
| preferTerminalReason(UserException) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| setIsProfileSafeStmt(boolean) | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
| lambda$assignAdaptiveRandomBucketForFragment$0(TPipelineFragmentParams) | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
| computeColocateJoinInstanceParam(PlanFragmentId, int, Coordinator.FragmentExecParams, boolean) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$sendPipelineCtx$3(AtomicLong, Coordinator.PipelineExecContexts) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| Coordinator(Long, TUniqueId, DescriptorTable, List, List, String, boolean, boolean) | | 94% | | 50% | 1 | 2 | 2 | 56 | 0 | 1 |
| deepCopyOlapTableSinkForCurrentBackend(TPipelineFragmentParams) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| updateDeltas(List) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| getQueryStatus() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$updateCommitInfos$12(Map, TTabletCommitInfo) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| chooseHostWithSelection(ImmutableMap, Reference) | | 75% | | 83% | 1 | 4 | 3 | 13 | 0 | 1 |
| isQueryCancelled() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| updateProfileIfPresent(Consumer) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$computeFragmentHosts$15(Integer, ScanNode) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| Coordinator(ConnectContext, Planner, StatsErrorEstimator, long) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| selectBackendsByRoundRobin(TScanRangeLocations, Map, Map, Reference, boolean) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| isTimeout() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$assignScanRanges$23(int, ScanNode) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| Coordinator(ConnectContext, Planner, StatsErrorEstimator) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| sortScanNodes() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| processFragmentAssignmentAndParams() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| sortScanRangeLocations(List) | | 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 |
| lambda$sendPipelineCtx$9(List, SummaryProfile) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$sendPipelineCtx$6(List, SummaryProfile) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| Coordinator(ConnectContext, Planner) | | 97% | | 75% | 1 | 3 | 1 | 61 | 0 | 1 |
| recordLoadSinkCoordinator() | | 91% | | 50% | 6 | 7 | 5 | 15 | 0 | 1 |
| applyBackendSelection(List, boolean) | | 89% | | 64% | 5 | 8 | 2 | 15 | 0 | 1 |
| lambda$sendPipelineCtx$4(AtomicLong, SummaryProfile) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setGroupCommitBe(Backend) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setTWorkloadGroups(List) | | 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 |
| lock() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| unlock() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getDispatchedBackendIdsForAudit() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$assignRuntimeFilterAddr$16(RuntimeFilterId) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$sendPipelineCtx$11(Map, SummaryProfile) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$sendPipelineCtx$8(Map, SummaryProfile) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getTWorkloadGroups() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getExecutionProfile() | | 0% | | n/a | 1 | 1 | 1 | 1 | 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 |
| 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 |
| getFragmentExecParamsMap() | | 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 |
| lambda$computeScanRangeAssignment$18(ScanNode) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$assignRuntimeFilterAddr$17(Coordinator.FInstanceExecParam) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$sendPipelineCtx$10(SummaryProfile) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$sendPipelineCtx$7(SummaryProfile) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$sendPipelineCtx$5(SummaryProfile) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$execInternal$2(SummaryProfile) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$exec$1(WorkloadGroup) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| mustOutliveDispatch() | | 91% | | 83% | 1 | 4 | 1 | 7 | 0 | 1 |
| lambda$recordQueryBackendSelection$22(TScanRangeLocation) | | 86% | | 50% | 1 | 2 | 0 | 2 | 0 | 1 |
| lambda$applyBackendSelection$20(TScanRangeLocation) | | 86% | | 50% | 1 | 2 | 0 | 2 | 0 | 1 |
| getQueryBackendSelectionDecision() | | 77% | | 50% | 1 | 2 | 1 | 3 | 0 | 1 |
| lambda$computeScanRangeAssignment$19(PlanFragmentId) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| recordQueryBackendSelection(boolean, TScanRangeLocation) | | 96% | | 50% | 3 | 4 | 1 | 7 | 0 | 1 |
| recordLoadCoordinator(BackendSelection.SelectionHint, Long) | | 94% | | 50% | 2 | 3 | 1 | 4 | 0 | 1 |
| isLoadSelectionCoordinator() | | 93% | | 50% | 3 | 4 | 0 | 2 | 0 | 1 |
| selectBackendsByRoundRobin(List, Map, Map, Reference) | | 100% | | 80% | 2 | 6 | 0 | 18 | 0 | 1 |
| firstAvailableLoadBackend(List, Reference) | | 100% | | 100% | 0 | 3 | 0 | 6 | 0 | 1 |
| hasAvailableQueryBackend(List) | | 100% | | 100% | 0 | 3 | 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 |
| setQueryType(TQueryType) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| resolveLoadSelectionHint() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getQueryOptions() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |