TableStreamManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total495 of 88944%63 of 9634%457097183522
fillTableStreamValuesMetadataResult(List)23293%1715%910373901
replayPruneTableStreamPartitionOffsets(PruneTableStreamPartitionOffsetInfo.Entry)860%140%88232311
cleanupStalePartitionOffsets(OlapTableStream)665143%15937%1213173001
cleanupStalePartitionOffsets()298875%3975%3752301
getTableStreamIds(DatabaseIf)270%n/a115511
replayPruneTableStreamPartitionOffsets(PruneTableStreamPartitionOffsetInfo)260%80%556611
fillStreamConsumptionValuesMetadataResult(List)126384%5758%4721601
lambda$removeStaleDbAndStream$4(Pair)110%n/a112211
lambda$removeStaleDbAndStream$3(Pair, Set)60%n/a111111
copyDbStreamMap()39100%2100%020701
removeStaleDbAndStream(List, List)24100%1375%130701
addTableStream(BaseTableStream)23100%n/a010401
removeStaleStream(BaseTableStream)21100%n/a010501
TableStreamManager()19100%n/a010401
gsonPostProcess()13100%n/a010301
write(DataOutput)9100%n/a010301
read(DataInput)9100%n/a010201
lambda$removeStaleStream$1(BaseTableStream, Set)7100%n/a010101
lambda$removeStaleDbAndStream$2(Long)6100%n/a010101
runAfterCatalogReady()5100%2100%020301
lambda$addTableStream$0(Long)4100%n/a010101
static {...}4100%n/a010101