(ignite-3) branch main updated: IGNITE-23343 Fix main branch after merge (#4495)

[apkhmv]

This is an automated email from the ASF dual-hosted git repository.

apkhmv pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new 9dd902f092 IGNITE-23343 Fix main branch after merge (#4495)
9dd902f092 is described below

commit 9dd902f092f5139f36a2c5a3f65a75472ce08ad7
Author: Vadim Pakhnushev <8614891+valep...@users.noreply.github.com>
AuthorDate: Thu Oct 3 11:18:23 2024 +0300

    IGNITE-23343 Fix main branch after merge (#4495)
---
 .../internal/restart/RestartProofIgniteCatalog.java  | 20 ++++++++++++++++++++
 1 file changed, 20 insertions(+)

diff --git 
a/modules/runner/src/main/java/org/apache/ignite/internal/restart/RestartProofIgniteCatalog.java
 
b/modules/runner/src/main/java/org/apache/ignite/internal/restart/RestartProofIgniteCatalog.java
index be4e2af997..8e5972b928 100644
--- 
a/modules/runner/src/main/java/org/apache/ignite/internal/restart/RestartProofIgniteCatalog.java
+++ 
b/modules/runner/src/main/java/org/apache/ignite/internal/restart/RestartProofIgniteCatalog.java
@@ -88,6 +88,16 @@ class RestartProofIgniteCatalog implements IgniteCatalog, 
Wrapper {
         });
     }
 
+    @Override
+    public CompletableFuture<TableDefinition> tableDefinitionAsync(String 
tableName) {
+        return attachmentLock.attachedAsync(ignite -> 
ignite.catalog().tableDefinitionAsync(tableName));
+    }
+
+    @Override
+    public TableDefinition tableDefinition(String tableName) {
+        return attachmentLock.attached(ignite -> 
ignite.catalog().tableDefinition(tableName));
+    }
+
     private Table wrapTable(Table table, Ignite ignite) {
         return new RestartProofTable(attachmentLock, ignite, 
RestartProofTable.tableId(table));
     }
@@ -102,6 +112,16 @@ class RestartProofIgniteCatalog implements IgniteCatalog, 
Wrapper {
         attachmentLock.consumeAttached(ignite -> 
ignite.catalog().createZone(definition));
     }
 
+    @Override
+    public CompletableFuture<ZoneDefinition> zoneDefinitionAsync(String 
zoneName) {
+        return attachmentLock.attachedAsync(ignite -> 
ignite.catalog().zoneDefinitionAsync(zoneName));
+    }
+
+    @Override
+    public ZoneDefinition zoneDefinition(String zoneName) {
+        return attachmentLock.attached(ignite -> 
ignite.catalog().zoneDefinition(zoneName));
+    }
+
     @Override
     public CompletableFuture<Void> dropTableAsync(TableDefinition definition) {
         return attachmentLock.attachedAsync(ignite -> 
ignite.catalog().dropTableAsync(definition));