submitPushTasks() |  | 0% |  | 0% | 19 | 19 | 77 | 77 | 1 | 1 |
createEtlPartitionInfo(OlapTable, Set) |  | 0% |  | 0% | 15 | 15 | 50 | 50 | 1 | 1 |
getLoadMeta(Map) |  | 0% |  | 0% | 9 | 9 | 42 | 42 | 1 | 1 |
getTBrokerScanRange(DescriptorTable, TupleDescriptor, List, Map) |  | 0% |  | 0% | 5 | 5 | 41 | 41 | 1 | 1 |
buildPushTask(long, OlapTable, long, long, long, long, long, int, int, long) |  | 0% |  | 0% | 3 | 3 | 29 | 29 | 1 | 1 |
createEtlIndexes(OlapTable) |  | 0% |  | 0% | 10 | 10 | 33 | 33 | 1 | 1 |
updateJobStatus(Map) |  | 0% |  | 0% | 2 | 2 | 22 | 22 | 1 | 1 |
updateLoadingStatus() |  | 0% |  | 0% | 11 | 11 | 23 | 23 | 1 | 1 |
createEtlColumn(Column, boolean) |  | 0% |  | 0% | 10 | 10 | 24 | 24 | 1 | 1 |
clearJob() |  | 0% |  | 0% | 7 | 7 | 20 | 20 | 1 | 1 |
readFields(DataInput) |  | 0% |  | 0% | 4 | 4 | 18 | 18 | 1 | 1 |
unprotectedPrepareLoadingInfos() |  | 0% |  | 0% | 4 | 4 | 13 | 13 | 1 | 1 |
unprotectedUpdateToLoadingState(EtlStatus, Map) |  | 0% |  | 0% | 3 | 3 | 17 | 17 | 1 | 1 |
checkIndexSchema(long, int, int) |  | 0% |  | 0% | 5 | 5 | 6 | 6 | 1 | 1 |
IngestionLoadJob(long, String, List, UserIdentity) |  | 0% | | n/a | 1 | 1 | 19 | 19 | 1 | 1 |
tryCommitJob() |  | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
replayUpdateStateInfo(LoadJob.LoadJobStateUpdateInfo) |  | 0% |  | 0% | 6 | 6 | 16 | 16 | 1 | 1 |
IngestionLoadJob() |  | 0% | | n/a | 1 | 1 | 17 | 17 | 1 | 1 |
updateState(String, String) |  | 0% |  | 0% | 5 | 5 | 13 | 13 | 1 | 1 |
updateEtlStatus() |  | 0% |  | 0% | 6 | 6 | 11 | 11 | 1 | 1 |
addFinishedReplica(long, long, long) |  | 0% |  | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
getLoadTableIds(List) |  | 0% |  | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
castToSlot(SlotDescriptor, Expr) |  | 0% |  | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
getTableNames() |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
beginTransaction() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
unprotectedLogUpdateStateInfo() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
unprotectedProcessEtlFinish() |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
checkState(JobState) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
startEtlJob() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
lambda$getLoadMeta$3(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getLoadMeta$2(Long) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getLoadTableIds$1(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getLoadTableIds$0(Long) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
afterAborted(TransactionState, boolean, String) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
cancelJobWithoutCheck(FailMsg, boolean, boolean) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
afterVisible(TransactionState, boolean) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
cancelJob(FailMsg) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getTDescriptorTable(DescriptorTable) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setEtlStatus(EtlStatus) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getEtlStartTimestamp() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTableNamesForShow() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |