clearJob() |  | 0% |  | 0% | 13 | 13 | 39 | 39 | 1 | 1 |
submitPushTasks() |   | 77% |   | 73% | 11 | 22 | 21 | 104 | 0 | 1 |
unprotectedUpdateEtlStatusInternal(EtlStatus) |   | 17% |   | 50% | 2 | 3 | 11 | 17 | 0 | 1 |
tryCommitJob() |   | 50% |   | 25% | 4 | 5 | 18 | 30 | 0 | 1 |
readFields(DataInput) |  | 0% |  | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
replayUpdateStateInfo(LoadJob.LoadJobStateUpdateInfo) |  | 0% |  | 0% | 3 | 3 | 13 | 13 | 1 | 1 |
onPendingTaskFinished(SparkPendingTaskAttachment) |   | 46% |   | 50% | 2 | 3 | 6 | 17 | 0 | 1 |
clearSparkLauncherLog() |  | 0% |  | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
unprotectedUpdateToLoadingState(EtlStatus, Map) |   | 74% |   | 75% | 1 | 3 | 4 | 16 | 0 | 1 |
unprotectedExecuteJob() |   | 70% | | n/a | 0 | 1 | 3 | 11 | 0 | 1 |
setResourceInfo() |   | 76% |   | 75% | 1 | 3 | 1 | 11 | 0 | 1 |
updateLoadingStatus() |   | 87% |   | 50% | 9 | 10 | 3 | 21 | 0 | 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 |
updateEtlStatus() |   | 90% |   | 75% | 2 | 6 | 2 | 16 | 0 | 1 |
afterVisible(TransactionState, boolean) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
cancelJob(FailMsg) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getHandle() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
unprotectedPrepareLoadingInfos() |  | 98% |   | 66% | 2 | 4 | 0 | 13 | 0 | 1 |
SparkLoadJob(long, String, ResourceDesc, OriginStatement, UserIdentity) |  | 100% | | n/a | 0 | 1 | 0 | 17 | 0 | 1 |
SparkLoadJob() |  | 100% | | n/a | 0 | 1 | 0 | 16 | 0 | 1 |
getPushBrokerReaderParams(OlapTable, long) |  | 100% |   | 50% | 1 | 2 | 0 | 7 | 0 | 1 |
addFinishedReplica(long, long, long) |  | 100% |   | 50% | 3 | 4 | 0 | 9 | 0 | 1 |
beginTxn() |  | 100% | | n/a | 0 | 1 | 0 | 6 | 0 | 1 |
unprotectedLogUpdateStateInfo() |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
unprotectedProcessEtlFinish(EtlStatus, SparkEtlJobHandler) |  | 100% |  | 100% | 0 | 2 | 0 | 7 | 0 | 1 |
checkState(JobState) |  | 100% |  | 100% | 0 | 2 | 0 | 5 | 0 | 1 |
lambda$getPushBrokerReaderParams$0(List, Column) |  | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
executeEtl() |  | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
onTaskFinished(TaskAttachment) |  | 100% |   | 50% | 1 | 2 | 0 | 3 | 0 | 1 |
setJobProperties(Map) |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
getResourceName() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
static {...} | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getEtlStartTimestamp() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |