IngestionLoadJob

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,746 of 2,7460%228 of 2280%1591595595594242
submitPushTasks()3630%360%1919777711
createEtlPartitionInfo(OlapTable, Set)2570%280%1515505011
getLoadMeta(Map)2140%160%99424211
getTBrokerScanRange(DescriptorTable, TupleDescriptor, List, Map)1900%80%55414111
buildPushTask(long, OlapTable, long, long, long, long, long, int, int, long)1760%40%33292911
createEtlIndexes(OlapTable)1570%160%1010333311
updateJobStatus(Map)1470%20%22222211
updateLoadingStatus()940%200%1111232311
createEtlColumn(Column, boolean)890%180%1010242411
clearJob()860%120%77202011
readFields(DataInput)850%60%44181811
unprotectedPrepareLoadingInfos()770%60%44131311
unprotectedUpdateToLoadingState(EtlStatus, Map)760%40%33171711
checkIndexSchema(long, int, int)670%80%556611
IngestionLoadJob(long, String, List, UserIdentity)640%n/a11191911
tryCommitJob()590%n/a11101011
replayUpdateStateInfo(LoadJob.LoadJobStateUpdateInfo)570%90%66161611
IngestionLoadJob()540%n/a11171711
updateState(String, String)490%60%55131311
updateEtlStatus()440%90%66111111
addFinishedReplica(long, long, long)400%60%449911
getLoadTableIds(List)380%20%228811
castToSlot(SlotDescriptor, Expr)340%60%447711
getTableNames()330%20%227711
beginTransaction()270%n/a115511
unprotectedLogUpdateStateInfo()270%n/a113311
unprotectedProcessEtlFinish()190%20%226611
checkState(JobState)140%20%223311
startEtlJob()140%n/a115511
lambda$getLoadMeta$3(String)120%n/a111111
lambda$getLoadMeta$2(Long)120%n/a111111
lambda$getLoadTableIds$1(String)120%n/a111111
lambda$getLoadTableIds$0(Long)120%n/a111111
afterAborted(TransactionState, boolean, String)80%n/a113311
cancelJobWithoutCheck(FailMsg, boolean, boolean)80%n/a113311
afterVisible(TransactionState, boolean)70%n/a113311
cancelJob(FailMsg)60%n/a113311
getTDescriptorTable(DescriptorTable)50%n/a112211
setEtlStatus(EtlStatus)40%n/a111111
static {...}40%n/a111111
getEtlStartTimestamp()0%n/a111111
getTableNamesForShow()0%n/a111111