SourceOffsetProvider

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total14 of 140%0 of 0n/a101010101010
getCommitOffsetJson(Offset, long, List)30%n/a111111
getPersistInfo()20%n/a111111
hasReachedEnd()20%n/a111111
ensureInitialized(Long, Map)10%n/a111111
initOnCreate()10%n/a111111
validateAlterOffset(String)10%n/a111111
replayIfNeed(StreamingInsertJob)10%n/a111111
restoreFromPersistInfo(String)10%n/a111111
onTaskCommitted(long, long)10%n/a111111
applyEndOffsetToTask(Offset, Offset)10%n/a111111