| computeFragmentHosts() |  | 0% | | 0% | 57 | 57 | 153 | 153 | 1 | 1 |
| sendPipelineCtx() | | 0% | | 0% | 27 | 27 | 104 | 104 | 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 |
| computeMultiCastFragmentParams() | | 0% | | 0% | 19 | 19 | 58 | 58 | 1 | 1 |
| updateFragmentExecStatus(TReportExecStatusParams) | | 0% | | 0% | 26 | 26 | 67 | 67 | 1 | 1 |
| execInternal() | | 0% | | 0% | 14 | 14 | 55 | 55 | 1 | 1 |
| computeScanRangeAssignment() | | 0% | | 0% | 21 | 21 | 50 | 50 | 1 | 1 |
| Coordinator(Long, TUniqueId, DescriptorTable, List, List, String, boolean, boolean) | | 0% | | 0% | 2 | 2 | 55 | 55 | 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 |
| updateLoadCounters(Map) | | 0% | | 0% | 7 | 7 | 27 | 27 | 1 | 1 |
| assignRuntimeFilterAddr() | | 0% | | 0% | 5 | 5 | 18 | 18 | 1 | 1 |
| selectBackendsByRoundRobin(List, Map, Map, Reference) | | 0% | | 0% | 6 | 6 | 18 | 18 | 1 | 1 |
| computeScanRangeAssignmentByScheduler(ScanNode, List, Coordinator.FragmentScanRangeAssignment, Map, Map, boolean) | | 0% | | 0% | 2 | 2 | 15 | 15 | 1 | 1 |
| cancel(Status) | | 0% | | 0% | 6 | 6 | 19 | 19 | 1 | 1 |
| exec() | | 0% | | 0% | 5 | 5 | 20 | 20 | 1 | 1 |
| selectBackendsByRoundRobin(TScanRangeLocations, Map, Map, Reference, boolean) | | 0% | | 0% | 6 | 6 | 18 | 18 | 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 |
| lambda$computeFragmentExecParams$12(Map, Coordinator.FragmentExecParams, Coordinator.FInstanceExecParam) | | 0% | | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
| lambda$computeMultiCastFragmentParams$13(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 |
| 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 |
| getBeToInstancesNum() | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| shouldQueue() | | 0% | | 0% | 7 | 7 | 10 | 10 | 1 | 1 |
| close() | | 0% | | 0% | 4 | 4 | 12 | 12 | 1 | 1 |
| checkBackendState() | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| updateStatus(Status) | | 0% | | 0% | 5 | 5 | 11 | 11 | 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 |
| 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 |
| toBrpcHost(TNetworkAddress) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| toArrowFlightHost(TNetworkAddress) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| Coordinator(ConnectContext, Planner) |  | 91% | | 50% | 3 | 4 | 4 | 65 | 0 | 1 |
| toRpcHost(TNetworkAddress) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 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 |
| findOrInsert(Map, Object, Object) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| setIsProfileSafeStmt(boolean) | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
| setFromUserProperty(ConnectContext) | | 63% | | 50% | 2 | 3 | 3 | 10 | 0 | 1 |
| computeColocateJoinInstanceParam(PlanFragmentId, int, Coordinator.FragmentExecParams, boolean) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$sendPipelineCtx$2(AtomicLong, Coordinator.PipelineExecContexts) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 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 |
| isQueryCancelled() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| updateProfileIfPresent(Consumer) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$computeFragmentHosts$14(Integer, ScanNode) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| initQueryOptions(ConnectContext) | | 80% | | 50% | 2 | 3 | 1 | 9 | 0 | 1 |
| isTimeout() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$assignScanRanges$19(int, ScanNode) | | 0% | | 0% | 2 | 2 | 1 | 1 | 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 |
| 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 |
| lambda$sendPipelineCtx$8(List, SummaryProfile) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$sendPipelineCtx$5(List, SummaryProfile) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$sendPipelineCtx$3(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 |
| lambda$assignRuntimeFilterAddr$15(RuntimeFilterId) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$sendPipelineCtx$10(Map, SummaryProfile) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$sendPipelineCtx$7(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 |
| getQueryOptions() | | 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$17(ScanNode) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$assignRuntimeFilterAddr$16(Coordinator.FInstanceExecParam) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$sendPipelineCtx$9(SummaryProfile) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$sendPipelineCtx$6(SummaryProfile) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$sendPipelineCtx$4(SummaryProfile) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$execInternal$1(SummaryProfile) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$exec$0(WorkloadGroup) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$computeScanRangeAssignment$18(PlanFragmentId) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| static {...} | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| Coordinator(ConnectContext, Planner, StatsErrorEstimator) | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |