| installCloudReadStates(Map) |  | 0% | | 0% | 11 | 11 | 21 | 21 | 1 | 1 |
| selectNonEmptyPartitionIds(Collection, Optional) | | 0% | | 0% | 6 | 6 | 13 | 13 | 1 | 1 |
| OlapTableStreamWrapper(OlapTableStream, OlapTable, List) | | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
| buildOutputUpdateMap(List) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| lambda$installCloudReadStates$0(Long, Cloud.TableStreamPartitionReadStatePB) | | 0% | | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
| lambda$filterIncrementalPartitionIds$6(Long) | | 0% | | 0% | 4 | 4 | 3 | 3 | 1 | 1 |
| filterHistoryPartitionIds(List) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| filterIncrementalPartitionIds(List) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| filterConsumedPartitionIds(List) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| filterNormalSnapshotPartitionIds(List) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| isHistoryPartition(long) | | 0% | | 0% | 3 | 3 | 3 | 3 | 1 | 1 |
| lambda$filterNormalSnapshotPartitionIds$13(Long) | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
| lambda$filterIncrementalPartitionIds$7(Long) | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
| getCloudIdentity() | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| lambda$selectNonEmptyPartitionIds$3(Long) | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
| lambda$getCloudVisibleVersions$2(Long) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| getCloudVisibleVersions(Collection) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getPartitionOffsets(List) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| getHistoryPartitionOffsets(List) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$filterNormalSnapshotPartitionIds$14(Long) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$filterConsumedPartitionIds$8(Long) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$filterHistoryPartitionIds$4(Long) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| getStreamScanType() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| getColumnDesc(long, List, List, List) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$getHistoryPartitionOffsets$12(Map.Entry) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| hasDeleteSign() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| getPartition(String, boolean) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getStreamDbId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$filterConsumedPartitionIds$9(Long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$filterHistoryPartitionIds$5(Long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getBaseSchema(boolean) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getIndexSchemaVersion(long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getIndexMetaByIndexId(long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getPartition(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getPartition(long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getStreamId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getBaseDbId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getBaseTableId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getHistoryPartitionOffsets$11(List, Map.Entry) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getPartitionOffsets$10(List, Map.Entry) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getBaseSchema() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getIndexNameById(long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getBaseIndexId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getSchemaByIndexId(Long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getPartitionIds() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getEnableUniqueKeyMergeOnWrite() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| isMorTable() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getPartitions() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| hasCloudReadStates() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getCloudReadStates() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getOutputUpdateMap() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getBaseTable() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getStreamKeysType() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| isDupKeysOrMergeOnWrite() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getCloudVisibleVersions$1(Long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |