NereidsCoordinator

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total550 of 94341%63 of 9030%801061142063661
cancel(Status)720%80%55161611
setForArrowFlight(CoordinatorContext, PipelineDistributedPlan)601520%11321%78131801
NereidsCoordinator(Long, TUniqueId, DescriptorTable, List, List, List, String, boolean, boolean)490%40%338811
getBeToInstancesNum()460%40%338811
getFragmentInstanceInfos()430%60%449911
setForBroker(CoordinatorContext, PipelineDistributedPlan)29719%3125%236901
setTimeout(int)270%20%225511
isTimeout()130%20%221111
close()103979%2466%2441201
enqueue(ConnectContext)87290%5550%5621901
getInvolvedBackends()80%n/a111111
NereidsCoordinator(ConnectContext, NereidsPlanner, StatsErrorEstimator)73984%5337%4511001
setQueryType(TQueryType)70%n/a112211
setLoadZeroTolerance(boolean)70%n/a112211
getQueueToken()70%n/a111111
setMemTableOnSinkNode(boolean)70%n/a112211
setBatchSize(int)70%n/a112211
setLoadMemLimit(long)70%n/a112211
setExecMemoryLimit(long)70%n/a112211
cancelInternal(Status)70%n/a112211
shouldQueue(ConnectContext)63183%6650%673901
join(int)60%n/a111111
updateFragmentExecStatus(TReportExecStatusParams)60%n/a112211
getLoadCounters()60%n/a111111
getDeltaUrls()60%n/a111111
getCommitInfos()60%n/a111111
getExportFiles()60%n/a111111
getTxnId()60%n/a111111
getLabel()60%n/a111111
getTrackingUrl()60%n/a111111
getFirstErrorMsg()60%n/a111111
getErrorTabletInfos()60%n/a111111
lambda$cancelInternal$0(Status)60%n/a111111
getNumReceivedRows()50%n/a111111
isDone()50%n/a111111
getJobId()4969%1150%121401
asQueryProcessor()40%n/a111111
asLoadProcessor()40%n/a111111
getTWorkloadGroups()40%n/a111111
getQueryId()40%n/a111111
getExecStatus()40%n/a111111
getConnectContext()40%n/a111111
getCoordinatorContext()30%n/a111111
setIsProfileSafeStmt(boolean)21487%2250%230201
NereidsCoordinator(ConnectContext, NereidsPlanner, StatsErrorEstimator, long)13296%2250%230701
exec()36100%n/a010801
setForInsert(long)24100%n/a010501
processTopSink(CoordinatorContext, PipelineDistributedPlan)9100%n/a010301
setForQuery()9100%n/a010301
getScanRangeNum()7100%n/a010101
setTxnId(long)7100%n/a010201
setTWorkloadGroups(List)5100%n/a010201
isQueryCancelled()5100%n/a010101
getNext()5100%n/a010101
isEos()5100%n/a010101
getJobProcessor()4100%n/a010101
getQueryOptions()4100%n/a010101
getFragments()4100%n/a010101
getExecutionProfile()4100%n/a010101
static {...}4100%n/a010101
lambda$enqueue$1(WorkloadGroup)3100%n/a010101