(ignite-3) branch main updated: IGNITE-21898 Remove reactive methods from AntiHijackingIgniteSql (#3534)

[ibessonov]

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

ibessonov 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 78e446b9a7 IGNITE-21898 Remove reactive methods from 
AntiHijackingIgniteSql (#3534)
78e446b9a7 is described below

commit 78e446b9a7851f9cc3cc0ecb529c44ac449c7456
Author: Roman Puchkovskiy <roman.puchkovs...@gmail.com>
AuthorDate: Mon Apr 1 18:52:25 2024 +0400

    IGNITE-21898 Remove reactive methods from AntiHijackingIgniteSql (#3534)
---
 .../internal/sql/api/AntiHijackIgniteSql.java      | 22 ----------------------
 1 file changed, 22 deletions(-)

diff --git 
a/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/AntiHijackIgniteSql.java
 
b/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/AntiHijackIgniteSql.java
index 24e29c55d4..e8bd5261de 100644
--- 
a/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/AntiHijackIgniteSql.java
+++ 
b/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/AntiHijackIgniteSql.java
@@ -19,7 +19,6 @@ package org.apache.ignite.internal.sql.api;
 
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.Executor;
-import java.util.concurrent.Flow.Publisher;
 import org.apache.ignite.internal.thread.PublicApiThreading;
 import org.apache.ignite.internal.wrapper.Wrapper;
 import org.apache.ignite.sql.BatchedArguments;
@@ -29,7 +28,6 @@ import org.apache.ignite.sql.SqlRow;
 import org.apache.ignite.sql.Statement;
 import org.apache.ignite.sql.Statement.StatementBuilder;
 import org.apache.ignite.sql.async.AsyncResultSet;
-import org.apache.ignite.sql.reactive.ReactiveResultSet;
 import org.apache.ignite.table.mapper.Mapper;
 import org.apache.ignite.tx.Transaction;
 import org.jetbrains.annotations.Nullable;
@@ -124,16 +122,6 @@ public class AntiHijackIgniteSql implements IgniteSql, 
Wrapper {
         return preventThreadHijackForResultSet(sql.executeAsync(transaction, 
mapper, statement, arguments));
     }
 
-    @Override
-    public ReactiveResultSet executeReactive(@Nullable Transaction 
transaction, String query, @Nullable Object... arguments) {
-        return sql.executeReactive(transaction, query, arguments);
-    }
-
-    @Override
-    public ReactiveResultSet executeReactive(@Nullable Transaction 
transaction, Statement statement, @Nullable Object... arguments) {
-        return sql.executeReactive(transaction, statement, arguments);
-    }
-
     @Override
     public long[] executeBatch(@Nullable Transaction transaction, String 
dmlQuery, BatchedArguments batch) {
         return sql.executeBatch(transaction, dmlQuery, batch);
@@ -154,16 +142,6 @@ public class AntiHijackIgniteSql implements IgniteSql, 
Wrapper {
         return preventThreadHijack(sql.executeBatchAsync(transaction, 
statement, batch));
     }
 
-    @Override
-    public Publisher<Long> executeBatchReactive(@Nullable Transaction 
transaction, String query, BatchedArguments batch) {
-        return sql.executeBatchReactive(transaction, query, batch);
-    }
-
-    @Override
-    public Publisher<Long> executeBatchReactive(@Nullable Transaction 
transaction, Statement statement, BatchedArguments batch) {
-        return sql.executeBatchReactive(transaction, statement, batch);
-    }
-
     @Override
     public void executeScript(String query, @Nullable Object... arguments) {
         sql.executeScript(query, arguments);