This is an automated email from the ASF dual-hosted git repository. tkalkirill pushed a commit to branch ignite-26778 in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit 6b7e3d0fa654d1b5b7c27af86b69326fc2bf0281 Author: Kirill Tkalenko <[email protected]> AuthorDate: Mon Oct 20 08:59:19 2025 +0300 IGNITE-26778 wip --- .../apache/ignite/internal/storage/engine/MvTableStorage.java | 1 - .../main/java/org/apache/ignite/internal/table/TableImpl.java | 10 ++-------- 2 files changed, 2 insertions(+), 9 deletions(-) diff --git a/modules/storage-api/src/main/java/org/apache/ignite/internal/storage/engine/MvTableStorage.java b/modules/storage-api/src/main/java/org/apache/ignite/internal/storage/engine/MvTableStorage.java index ab70e6ced73..edbbe017971 100644 --- a/modules/storage-api/src/main/java/org/apache/ignite/internal/storage/engine/MvTableStorage.java +++ b/modules/storage-api/src/main/java/org/apache/ignite/internal/storage/engine/MvTableStorage.java @@ -231,7 +231,6 @@ public interface MvTableStorage extends ManuallyCloseable { * @return Index Storage. * @throws StorageException If the given partition does not exist. */ - // TODO: IGNITE-19112 Change or get rid of @Nullable IndexStorage getIndex(int partitionId, int indexId); /** diff --git a/modules/table/src/main/java/org/apache/ignite/internal/table/TableImpl.java b/modules/table/src/main/java/org/apache/ignite/internal/table/TableImpl.java index c93b073ff6f..36202a26f3b 100644 --- a/modules/table/src/main/java/org/apache/ignite/internal/table/TableImpl.java +++ b/modules/table/src/main/java/org/apache/ignite/internal/table/TableImpl.java @@ -283,10 +283,7 @@ public class TableImpl implements TableViewInternal { ) { int indexId = indexDescriptor.id(); - // TODO: https://issues.apache.org/jira/browse/IGNITE-19112 Create storages once. - partitions.stream().forEach(partitionId -> { - tbl.storage().createHashIndex(partitionId, indexDescriptor); - }); + partitions.stream().forEach(partitionId -> tbl.storage().createHashIndex(partitionId, indexDescriptor)); indexWrapperById.put(indexId, new HashIndexWrapper(tbl, lockManager, indexId, searchRowResolver, unique)); } @@ -300,10 +297,7 @@ public class TableImpl implements TableViewInternal { ) { int indexId = indexDescriptor.id(); - // TODO: https://issues.apache.org/jira/browse/IGNITE-19112 Create storages once. - partitions.stream().forEach(partitionId -> { - tbl.storage().createSortedIndex(partitionId, indexDescriptor); - }); + partitions.stream().forEach(partitionId -> tbl.storage().createSortedIndex(partitionId, indexDescriptor)); indexWrapperById.put(indexId, new SortedIndexWrapper(tbl, lockManager, indexId, searchRowResolver, unique)); }
