S3SourceOffsetProvider

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total102 of 67184%26 of 8067%246427148224
replayIfNeed(StreamingInsertJob)330%40%33101011
getShowMaxOffset()210%20%225511
getNextOffset(StreamingJobProperties, Map)2015688%41071%3833501
fetchRemoteMeta(Map)109390%41477%41012101
deserializeOffsetProperty(String)63585%4450%4531201
restoreFromPersistInfo(String)61164%1150%123701
getShowCurrentOffset()22090%1150%121501
getPersistInfo()2777%1150%121301
buildFileListUri(List)5198%1150%120701
lambda$getNextOffset$0(RemoteFile)1894%1150%120301
lambda$rewriteS3Tvf$3(String, List, Plan)34100%2100%020801
escapeGlob(String)33100%4100%030701
hasMoreDataToConsume()28100%2880%260701
hasReachedEnd()19100%1787%150201
rewriteS3Tvf(InsertIntoTableCommand, List)13100%n/a010301
updateOffset(Offset)9100%n/a010301
rewriteTvfParams(InsertIntoTableCommand, Offset, long)8100%n/a010201
S3SourceOffsetProvider(StreamingJobProperties)7100%n/a010301
S3SourceOffsetProvider()6100%n/a010301
deserializeOffset(String)6100%n/a010101
lambda$buildFileListUri$2(String, String)6100%n/a010101
static {...}4100%n/a010101
lambda$buildFileListUri$1(int)3100%n/a010101
getSourceType()2100%n/a010101