SourceOffsetProvider

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