TableStreamManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total575 of 1,35757%96 of 17043%75114129294829
fillCloudStreamConsumptionValuesMetadataResult(List, TableStreamManager.StreamConsumptionSelector)2000%320%1717505011
getCloudTableStreamsForBaseTable(long, long)940%140%88222211
cleanupStalePartitionOffsets(OlapTableStream)5510766%161242%1315154101
fillTableStreamValuesMetadataResult(List)5420579%121657%111584201
replayPrunePartitionOffset(TableStreamCleanupInfo.PartitionOffsetPruneEntry)384554%7750%78112201
fillLocalStreamConsumptionValuesMetadataResult(List, TableStreamManager.StreamConsumptionSelector)349874%81666%61362801
getTableStreamIds(DatabaseIf)270%n/a115511
cleanupStalePartitionOffsets()2210682%31178%3842501
lambda$removeStaleDbAndStream$4(Pair)110%n/a112211
lambda$fillCloudStreamConsumptionValuesMetadataResult$6(Map, Partition)90%n/a111111
lambda$fillCloudStreamConsumptionValuesMetadataResult$7(Map, Cloud.TableStreamIdentityPB, TableStreamManager.CloudStreamConsumptionSnapshot)80%n/a111111
lambda$getCloudTableStreamsForBaseTable$5(Cloud.TableStreamIdentityPB, Cloud.TableStreamIdentityPB)60%n/a111111
lambda$removeStaleDbAndStream$3(Pair, Set)60%n/a111111
fillStreamConsumptionValuesMetadataResult(List)5758%1150%122501
fillStreamConsumptionValuesMetadataResult(List, TableStreamManager.StreamConsumptionSelector)5758%1150%122501
replayTableStreamCleanup(TableStreamCleanupInfo)2496%1375%131701
copyDbStreamMap()39100%2100%020701
removeStaleDbAndStream(List, List)24100%1375%130701
addTableStream(BaseTableStream)23100%n/a010401
removeTableStream(BaseTableStream)21100%n/a010501
TableStreamManager()19100%n/a010401
gsonPostProcess()13100%n/a010301
write(DataOutput)9100%n/a010301
read(DataInput)9100%n/a010201
lambda$removeTableStream$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