SourceOffsetProvider

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total36 of 6645%4 of 40%153213311330
isSnapshotPhase()100%40%331111
validateAlterIncludeTables(List)50%n/a111111
applyIncludeTablesChange(List, List)50%n/a111111
hasPendingIncludeTablesChange()20%n/a111111
getTableSchemas()20%n/a111111
isTableSchemasDirty()20%n/a111111
getPersistInfo()20%n/a111111
hasReachedEnd()20%n/a111111
pendingSplitCount()20%n/a111111
markTableSchemasPersisted(String)10%n/a111111
replayIfNeed(StreamingInsertJob)10%n/a111111
restoreFromPersistInfo(String)10%n/a111111
advanceSplits()10%n/a111111
fetchRemoteMeta(StreamingJobProperties, Map)4100%n/a010201
getLag()4100%n/a010101
getCommitOffsetJson(Offset, long, List)3100%n/a010101
mergePersistInfo(String, String)2100%n/a010101
noMoreSplits()2100%n/a010101
getLagBytes()2100%n/a010101
getLagMessages()2100%n/a010101
getLastSourceEventTimestampSeconds()2100%n/a010101
ensureInitialized(Long, Map)1100%n/a010101
close()1100%n/a010101
initOnCreate(List)1100%n/a010101
setCloudCluster(String)1100%n/a010101
setBoundBackendId(long)1100%n/a010101
validateAlterOffset(String)1100%n/a010101
onTaskCommitted(long, long)1100%n/a010101
applyEndOffsetToTask(Offset, Offset)1100%n/a010101
resetLag()1100%n/a010101