LanceIndexJobManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total772 of 1,71354%149 of 24839%1211691593831545
recordTerminationProof(long, long, long, long, String, LanceIndexTerminationProof)1220%200%1111303011
transitionRefresh(long, long, LanceIndexJobRefreshState)1180%240%1313242411
gsonPostProcess()643636%9535%68132201
createJob(LanceIndexJob, long, long, long)5515774%61062%6974501
downgradeRunningRefresh(LanceIndexJob)430%40%33121211
markRunning(long, long, long, long, String, long)408267%5550%56103301
getUnresolvedJobs()400%80%558811
completeWithResultInternal(long, long, String, Long, LanceIndexJobResult, LanceIndexTerminationProof)3710974%9950%910103601
applyToMemory(LanceIndexJob)356565%6857%5862001
completePreInvocationRejected(long, long, String, Long, LanceIndexJobResult)330%40%335511
onTransferToMaster()293151%4450%3561401
hasDispatchIdentity(LanceIndexJob)190%100%662211
replayUpsertJob(LanceIndexJob)173164%2466%2451301
getExpiredRunningJobs(long)163165%6440%462901
getCorruptUnresolvedJobIds()120%n/a113311
isFenceHeld(LanceIndexFenceKey)110%n/a113311
getJobsHoldingPossibleLiveSlot()103075%4450%351801
getJobCount()100%n/a113311
completeWithResult(long, long, String, Long, LanceIndexJobResult)90%n/a111111
countPossibleLiveSlotsByBackend()83179%2675%251801
getJobsNeedingRefresh()74887%61062%6911201
markRefreshRunning(long, long)60%n/a111111
markRefreshDone(long, long)60%n/a111111
markRefreshFailed(long, long)60%n/a111111
hasUnresolvedJobsForCatalog(long)43188%2675%251701
lambda$gsonPostProcess$1(LanceIndexFenceKey)40%n/a111111
dispatchRevisionOf(LanceIndexJob)3770%1150%120101
getQuota()30%n/a111111
getJob(long)22090%1150%120401
hasDispatchTarget(LanceIndexJob)2996%8850%890401
removeFenceOwner(LanceIndexJob)2696%2250%231801
hasFenceIdentity(LanceIndexJob)1292%3350%340201
getJobsNeedingDispatch()45100%2675%2501001
getAllJobsSnapshot()38100%1375%130901
LanceIndexJobManager()25100%n/a010801
completeProvenNoEnqueue(long, long, String, Long, LanceIndexJobResult)9100%n/a010101
write(DataOutput)8100%n/a010201
read(DataInput)7100%n/a010101
readLock()5100%n/a010201
readUnlock()5100%n/a010201
writeLock()5100%n/a010201
writeUnlock()5100%n/a010201
writeEditLog(LanceIndexJob)5100%n/a010201
lambda$applyToMemory$0(LanceIndexFenceKey)4100%n/a010101
static {...}4100%n/a010101