TableStreamManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total479 of 1,20660%70 of 13849%5896100257627
fillTableStreamValuesMetadataResult(List)2410%180%1010393911
fillStreamConsumptionValuesMetadataResult(List)7567%1317%78161901
cleanupStalePartitionOffsets(OlapTableStream)449367%141450%1115133501
replayPrunePartitionOffset(TableStreamCleanupInfo.PartitionOffsetPruneEntry)384554%7750%78112201
cleanupStalePartitionOffsets()299676%51168%5962301
gsonPostProcess()130%n/a113311
write(DataOutput)90%n/a113311
read(DataInput)90%n/a112211
lambda$getCloudTableStreamsForBaseTable$5(Cloud.TableStreamIdentityPB, Cloud.TableStreamIdentityPB)60%n/a111111
lambda$removeStaleDbAndStream$2(Long)60%n/a111111
fillCloudStreamConsumptionValuesMetadataResult(List)416697%61672%61234201
getCloudTableStreamsForBaseTable(long, long)9297%41071%4822201
runAfterCatalogReady()360%1150%121301
replayTableStreamCleanup(TableStreamCleanupInfo)2496%1375%131701
copyDbStreamMap()39100%2100%020701
getTableStreamIds(DatabaseIf)27100%n/a010501
removeStaleDbAndStream(List, List)24100%1375%130701
addTableStream(BaseTableStream)23100%n/a010401
removeTableStream(BaseTableStream)21100%n/a010501
TableStreamManager()19100%n/a010401
lambda$removeStaleDbAndStream$4(Pair)11100%n/a010201
lambda$fillCloudStreamConsumptionValuesMetadataResult$6(Map, Partition)9100%n/a010101
lambda$fillCloudStreamConsumptionValuesMetadataResult$7(Map, Cloud.TableStreamIdentityPB, TableStreamManager.CloudStreamConsumptionSnapshot)8100%n/a010101
lambda$removeTableStream$1(BaseTableStream, Set)7100%n/a010101
lambda$removeStaleDbAndStream$3(Pair, Set)6100%n/a010101
lambda$addTableStream$0(Long)4100%n/a010101
static {...}4100%n/a010101