OlapTableStreamWrapper

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total104 of 71285%22 of 7871%2994191411155
lambda$filterNormalSnapshotPartitionIds$13(Long)190%40%332211
isHistoryPartition(long)13838%3125%231301
installCloudReadStates(Map)119589%81260%81122101
filterNormalSnapshotPartitionIds(List)91257%1150%123701
getColumnDesc(long, List, List, List)80%n/a112211
hasDeleteSign()70%20%221111
getPartition(String, boolean)60%n/a111111
getIndexSchemaVersion(long)50%n/a111111
getIndexMetaByIndexId(long)50%n/a111111
getPartition(String)50%n/a111111
getIndexNameById(long)40%n/a111111
getPartitions()40%n/a111111
getStreamKeysType()30%n/a111111
lambda$filterNormalSnapshotPartitionIds$14(Long)21083%1150%120101
isDupKeysOrMergeOnWrite()20%n/a111111
lambda$filterConsumedPartitionIds$8(Long)11191%1150%120101
selectNonEmptyPartitionIds(Collection, Optional)59100%10100%0601301
OlapTableStreamWrapper(OlapTableStream, OlapTable, List)42100%n/a0101001
buildOutputUpdateMap(List)33100%4100%030701
lambda$installCloudReadStates$0(Long, Cloud.TableStreamPartitionReadStatePB)25100%4100%030401
lambda$filterIncrementalPartitionIds$6(Long)23100%6100%040301
filterHistoryPartitionIds(List)21100%2100%020701
filterIncrementalPartitionIds(List)21100%2100%020701
filterConsumedPartitionIds(List)21100%2100%020701
lambda$filterIncrementalPartitionIds$7(Long)18100%1375%130201
getCloudIdentity()17100%n/a010601
lambda$selectNonEmptyPartitionIds$3(Long)17100%1375%130201
lambda$getCloudVisibleVersions$2(Long)15100%n/a010301
getCloudVisibleVersions(Collection)13100%n/a010201
getPartitionOffsets(List)13100%n/a010301
getHistoryPartitionOffsets(List)13100%n/a010301
lambda$filterHistoryPartitionIds$4(Long)12100%2100%020101
getStreamScanType()10100%2100%020301
lambda$getHistoryPartitionOffsets$12(Map.Entry)8100%n/a010101
getStreamDbId()6100%n/a010101
lambda$filterConsumedPartitionIds$9(Long)6100%n/a010101
lambda$filterHistoryPartitionIds$5(Long)6100%n/a010101
getBaseSchema(boolean)5100%n/a010101
getPartition(long)5100%n/a010101
getStreamId()5100%n/a010101
getBaseDbId()5100%n/a010101
getBaseTableId()5100%n/a010101
lambda$getHistoryPartitionOffsets$11(List, Map.Entry)5100%n/a010101
lambda$getPartitionOffsets$10(List, Map.Entry)5100%n/a010101
getBaseSchema()4100%n/a010101
getBaseIndexId()4100%n/a010101
getSchemaByIndexId(Long)4100%n/a010101
getPartitionIds()4100%n/a010101
getEnableUniqueKeyMergeOnWrite()4100%n/a010101
isMorTable()4100%n/a010101
hasCloudReadStates()3100%n/a010101
getCloudReadStates()3100%n/a010101
getOutputUpdateMap()3100%n/a010101
getBaseTable()3100%n/a010101
lambda$getCloudVisibleVersions$1(Long)2100%n/a010101