TableStreamManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total430 of 2,20780%109 of 29863%95190109481341
keepAliveCloudPartitions(TableStreamManager.CloudKeepAliveSnapshot, Map, long)682022%9110%56152001
cleanupStalePartitionOffsets(OlapTableStream)5111168%151346%1215144101
keepAliveIdlePartitions(OlapTableStream)5022781%183062%1525146001
replayPrunePartitionOffset(TableStreamCleanupInfo.PartitionOffsetPruneEntry)384554%7750%78112201
fillLocalStreamConsumptionValuesMetadataResult(List, TableStreamManager.StreamConsumptionSelector)349874%81666%61362801
snapshotForCloudKeepAlive(OlapTableStream)307872%11945%91192701
replayKeepAlive(TableStreamCleanupInfo.PartitionKeepAliveEntry)273858%4450%4571601
keepAliveIdleCloudPartitions(List, int)2610980%51372%51093201
cleanupStalePartitionOffsets()2210682%31178%3842501
fillTableStreamValuesMetadataResult(List)2023992%72175%61544201
keepAliveCloudBatch(List, long, List)144475%1375%1351501
lambda$keepAliveCloudPartitions$9(TableStreamManager.CloudKeepAliveSnapshot, long, long, Map, Long, Cloud.TableStreamPartitionReadStatePB)124478%61062%5911001
fillCloudStreamConsumptionValuesMetadataResult(List, TableStreamManager.StreamConsumptionSelector)1118994%102268%91765001
lambda$removeStaleDbAndStream$4(Pair)110%n/a112211
lambda$getCloudTableStreamsForBaseTable$5(Cloud.TableStreamIdentityPB, Cloud.TableStreamIdentityPB)60%n/a111111
lambda$removeStaleDbAndStream$3(Pair, Set)60%n/a111111
lambda$keepAliveCloudBatch$7(TableStreamManager.CloudKeepAliveSnapshot)1386%1150%120201
getCloudTableStreamsForBaseTable(long, long)9398%21285%2812201
replayTableStreamCleanup(TableStreamCleanupInfo)3997%1583%1411001
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
gsonPostProcess()13100%n/a010301
lambda$keepAliveIdlePartitions$6(Map, OlapTableStream, Long, Long)13100%n/a010201
fillStreamConsumptionValuesMetadataResult(List)12100%2100%020501
fillStreamConsumptionValuesMetadataResult(List, TableStreamManager.StreamConsumptionSelector)12100%2100%020501
write(DataOutput)9100%n/a010301
read(DataInput)9100%n/a010201
lambda$fillCloudStreamConsumptionValuesMetadataResult$10(Map, Partition)9100%n/a010101
lambda$fillCloudStreamConsumptionValuesMetadataResult$11(Map, Cloud.TableStreamIdentityPB, TableStreamManager.CloudStreamConsumptionSnapshot)8100%n/a010101
lambda$keepAliveCloudBatch$8(Map, TableStreamManager.CloudKeepAliveSnapshot)8100%n/a010101
keepAliveRenewCutoffTso(long)7100%n/a010101
lambda$removeTableStream$1(BaseTableStream, Set)7100%n/a010101
lambda$removeStaleDbAndStream$2(Long)6100%n/a010101
runAfterCatalogReady()5100%2100%020301
keepAliveIdleCloudPartitions(List)5100%n/a010101
lambda$addTableStream$0(Long)4100%n/a010101
static {...}4100%n/a010101