TableStreamManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total489 of 88944%57 of 9640%4870100183822
fillTableStreamValuesMetadataResult(List)2410%180%1010393911
fillStreamConsumptionValuesMetadataResult(List)750%120%77161611
replayPruneTableStreamPartitionOffsets(PruneTableStreamPartitionOffsetInfo.Entry)384855%7750%78122301
cleanupStalePartitionOffsets(OlapTableStream)328572%111354%913103001
cleanupStalePartitionOffsets()298875%3975%3762301
removeStaleDbAndStream(List, List)17729%2250%235701
gsonPostProcess()130%n/a113311
lambda$removeStaleDbAndStream$4(Pair)110%n/a112211
write(DataOutput)90%n/a113311
read(DataInput)90%n/a112211
lambda$removeStaleDbAndStream$3(Pair, Set)60%n/a111111
lambda$removeStaleDbAndStream$2(Long)60%n/a111111
runAfterCatalogReady()360%1150%121301
replayPruneTableStreamPartitionOffsets(PruneTableStreamPartitionOffsetInfo)2596%3562%351601
copyDbStreamMap()39100%2100%020701
getTableStreamIds(DatabaseIf)27100%n/a010501
addTableStream(BaseTableStream)23100%n/a010401
removeStaleDbAndStream(BaseTableStream)21100%n/a010501
TableStreamManager()19100%n/a010401
lambda$removeStaleDbAndStream$1(BaseTableStream, Set)7100%n/a010101
lambda$addTableStream$0(Long)4100%n/a010101
static {...}4100%n/a010101