tkalkirill commented on code in PR #1305:
URL: https://github.com/apache/ignite-3/pull/1305#discussion_r1012861180
##########
modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/impl/TestMvTableStorage.java:
##########
@@ -40,50 +37,27 @@
* Test table storage implementation.
*/
public class TestMvTableStorage implements MvTableStorage {
- private final Map<Integer, MvPartitionStorage> partitions = new
ConcurrentHashMap<>();
+ private final Map<Integer, Storages> storagesByPartitionId = new
ConcurrentHashMap<>();
- private final Map<Integer, MvPartitionStorage> backupPartitions = new
ConcurrentHashMap<>();
-
- private final Map<UUID, SortedIndices> sortedIndicesById = new
ConcurrentHashMap<>();
-
- private final Map<UUID, HashIndices> hashIndicesById = new
ConcurrentHashMap<>();
+ private final Map<Integer, Storages> backupStoragesByPartitionId = new
ConcurrentHashMap<>();
private final TableConfiguration tableCfg;
private final TablesConfiguration tablesCfg;
/**
- * Class for storing Sorted Indices for a particular partition.
+ * Storages container for the partition.
*/
- private static class SortedIndices {
- private final SortedIndexDescriptor descriptor;
-
- final Map<Integer, SortedIndexStorage> storageByPartitionId = new
ConcurrentHashMap<>();
-
- SortedIndices(SortedIndexDescriptor descriptor) {
- this.descriptor = descriptor;
+ private static class Storages {
Review Comment:
Discussed to do it through delegates so that there are less problems when we
change storages.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
