TableStreamManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total870 of 1,20627%118 of 13814%77961852571427
fillTableStreamValuesMetadataResult(List)2410%180%1010393911
cleanupStalePartitionOffsets(OlapTableStream)1370%280%1515353511
cleanupStalePartitionOffsets()1250%160%99232311
getCloudTableStreamsForBaseTable(long, long)940%140%88222211
replayPrunePartitionOffset(TableStreamCleanupInfo.PartitionOffsetPruneEntry)830%140%88222211
fillStreamConsumptionValuesMetadataResult(List)7567%1317%78161901
replayTableStreamCleanup(TableStreamCleanupInfo)250%40%337711
removeStaleDbAndStream(List, List)240%40%337711
gsonPostProcess()130%n/a113311
lambda$removeStaleDbAndStream$4(Pair)110%n/a112211
write(DataOutput)90%n/a113311
read(DataInput)90%n/a112211
lambda$getCloudTableStreamsForBaseTable$5(Cloud.TableStreamIdentityPB, Cloud.TableStreamIdentityPB)60%n/a111111
lambda$removeStaleDbAndStream$3(Pair, Set)60%n/a111111
lambda$removeStaleDbAndStream$2(Long)60%n/a111111
fillCloudStreamConsumptionValuesMetadataResult(List)416697%61672%61234201
runAfterCatalogReady()360%1150%121301
copyDbStreamMap()39100%2100%020701
getTableStreamIds(DatabaseIf)27100%n/a010501
addTableStream(BaseTableStream)23100%n/a010401
removeTableStream(BaseTableStream)21100%n/a010501
TableStreamManager()19100%n/a010401
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$addTableStream$0(Long)4100%n/a010101
static {...}4100%n/a010101