OlapTableStreamWrapper

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total383 of 71246%54 of 7830%5594731412455
installCloudReadStates(Map)1060%200%1111212111
lambda$installCloudReadStates$0(Long, Cloud.TableStreamPartitionReadStatePB)250%40%334411
lambda$filterIncrementalPartitionIds$6(Long)230%60%443311
lambda$filterNormalSnapshotPartitionIds$13(Long)190%40%332211
getCloudIdentity()170%n/a116611
lambda$selectNonEmptyPartitionIds$3(Long)170%40%332211
lambda$getCloudVisibleVersions$2(Long)150%n/a113311
isHistoryPartition(long)13838%3125%231301
getCloudVisibleVersions(Collection)130%n/a112211
lambda$filterConsumedPartitionIds$8(Long)120%20%221111
lambda$filterHistoryPartitionIds$4(Long)120%20%221111
selectNonEmptyPartitionIds(Collection, Optional)95084%1990%1631301
filterHistoryPartitionIds(List)91257%1150%123701
filterIncrementalPartitionIds(List)91257%1150%123701
filterConsumedPartitionIds(List)91257%1150%123701
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
getBaseDbId()50%n/a111111
getBaseTableId()50%n/a111111
getIndexNameById(long)40%n/a111111
getPartitions()40%n/a111111
getCloudReadStates()30%n/a111111
getStreamKeysType()30%n/a111111
lambda$filterNormalSnapshotPartitionIds$14(Long)21083%1150%120101
isDupKeysOrMergeOnWrite()20%n/a111111
lambda$getCloudVisibleVersions$1(Long)20%n/a111111
OlapTableStreamWrapper(OlapTableStream, OlapTable, List)42100%n/a0101001
buildOutputUpdateMap(List)33100%4100%030701
lambda$filterIncrementalPartitionIds$7(Long)18100%1375%130201
getPartitionOffsets(List)13100%n/a010301
getHistoryPartitionOffsets(List)13100%n/a010301
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
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
getOutputUpdateMap()3100%n/a010101
getBaseTable()3100%n/a010101