TableStreamManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total442 of 88950%71 of 9626%467097183622
cleanupStalePartitionOffsets(OlapTableStream)1170%240%1313303011
replayPruneTableStreamPartitionOffsets(PruneTableStreamPartitionOffsetInfo.Entry)860%140%88232311
cleanupStalePartitionOffsets()684941%8433%57122301
fillStreamConsumptionValuesMetadataResult(List)512432%9325%57111601
fillTableStreamValuesMetadataResult(List)5019179%71161%61083901
getTableStreamIds(DatabaseIf)270%n/a115511
replayPruneTableStreamPartitionOffsets(PruneTableStreamPartitionOffsetInfo)260%80%556611
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
removeStaleDbAndStream(BaseTableStream)21100%n/a010501
TableStreamManager()19100%n/a010401
gsonPostProcess()13100%n/a010301
write(DataOutput)9100%n/a010301
read(DataInput)9100%n/a010201
lambda$removeStaleDbAndStream$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