TableStreamManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,280 of 1,3575%170 of 1700%1091142802942429
fillTableStreamValuesMetadataResult(List)2590%280%1515424211
fillCloudStreamConsumptionValuesMetadataResult(List, TableStreamManager.StreamConsumptionSelector)2000%320%1717505011
cleanupStalePartitionOffsets(OlapTableStream)1620%280%1515414111
fillLocalStreamConsumptionValuesMetadataResult(List, TableStreamManager.StreamConsumptionSelector)1320%240%1313282811
cleanupStalePartitionOffsets()1280%140%88252511
getCloudTableStreamsForBaseTable(long, long)940%140%88222211
replayPrunePartitionOffset(TableStreamCleanupInfo.PartitionOffsetPruneEntry)830%140%88222211
copyDbStreamMap()390%20%227711
replayTableStreamCleanup(TableStreamCleanupInfo)250%40%337711
removeStaleDbAndStream(List, List)240%40%337711
removeTableStream(BaseTableStream)210%n/a115511
gsonPostProcess()130%n/a113311
fillStreamConsumptionValuesMetadataResult(List)120%20%225511
fillStreamConsumptionValuesMetadataResult(List, TableStreamManager.StreamConsumptionSelector)120%20%225511
lambda$removeStaleDbAndStream$4(Pair)110%n/a112211
write(DataOutput)90%n/a113311
read(DataInput)90%n/a112211
lambda$fillCloudStreamConsumptionValuesMetadataResult$6(Map, Partition)90%n/a111111
lambda$fillCloudStreamConsumptionValuesMetadataResult$7(Map, Cloud.TableStreamIdentityPB, TableStreamManager.CloudStreamConsumptionSnapshot)80%n/a111111
lambda$removeTableStream$1(BaseTableStream, Set)70%n/a111111
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
runAfterCatalogReady()50%20%223311
getTableStreamIds(DatabaseIf)27100%n/a010501
addTableStream(BaseTableStream)23100%n/a010401
TableStreamManager()19100%n/a010401
lambda$addTableStream$0(Long)4100%n/a010101
static {...}4100%n/a010101