NereidsCoordinator

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total115 of 87186%17 of 8680%2510025189957
cancel(Status)244866%2675%2531601
getJobId()130%20%224411
close()103979%1583%1441201
enqueue(ConnectContext)87290%2880%2621901
setForArrowFlight(CoordinatorContext, PipelineDistributedPlan)86789%31178%3821801
setTimeout(int)81970%1150%121501
getScanRangeNum()70%n/a111111
setLoadMemLimit(long)70%n/a112211
getDeltaUrls()60%n/a111111
getExportFiles()60%n/a111111
asQueryProcessor()40%n/a111111
asLoadProcessor()40%n/a111111
getConnectContext()40%n/a111111
getFragments()40%n/a111111
NereidsCoordinator(Long, TUniqueId, DescriptorTable, List, List, List, String, boolean, boolean)14297%2250%230701
NereidsCoordinator(ConnectContext, NereidsPlanner, StatsErrorEstimator)13697%2250%230701
getBeToInstancesNum()46100%4100%030801
getFragmentInstanceInfos()43100%6100%040901
shouldQueue(ConnectContext)37100%21083%270901
exec()36100%n/a010801
setForBroker(CoordinatorContext, PipelineDistributedPlan)36100%4100%030901
buildJobProcessor(CoordinatorContext)18100%4100%030401
setIsProfileSafeStmt(boolean)16100%4100%030201
isTimeout()13100%2100%020101
processTopSink(CoordinatorContext, PipelineDistributedPlan)9100%n/a010301
getInvolvedBackends()8100%n/a010101
setQueryType(TQueryType)7100%n/a010201
setLoadZeroTolerance(boolean)7100%n/a010201
getQueueToken()7100%n/a010101
setTxnId(long)7100%n/a010201
setMemTableOnSinkNode(boolean)7100%n/a010201
setBatchSize(int)7100%n/a010201
setExecMemoryLimit(long)7100%n/a010201
cancelInternal(Status)7100%n/a010201
join(int)6100%n/a010101
updateFragmentExecStatus(TReportExecStatusParams)6100%n/a010201
getLoadCounters()6100%n/a010101
getCommitInfos()6100%n/a010101
getTxnId()6100%n/a010101
getLabel()6100%n/a010101
getTrackingUrl()6100%n/a010101
getErrorTabletInfos()6100%n/a010101
lambda$cancelInternal$0(Status)6100%n/a010101
setTWorkloadGroups(List)5100%n/a010201
isQueryCancelled()5100%n/a010101
getNext()5100%n/a010101
isEos()5100%n/a010101
getNumReceivedRows()5100%n/a010101
isDone()5100%n/a010101
getJobProcessor()4100%n/a010101
getTWorkloadGroups()4100%n/a010101
getQueryId()4100%n/a010101
getQueryOptions()4100%n/a010101
getExecStatus()4100%n/a010101
getExecutionProfile()4100%n/a010101
static {...}4100%n/a010101
lambda$enqueue$1(WorkloadGroup)3100%n/a010101