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

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


The following commit(s) were added to refs/heads/ignite-14972 by this push:
     new 3be08e4ad wip cleanup
3be08e4ad is described below

commit 3be08e4add1f5667e2ff63e8b9f0327af6f1f36a
Author: Pavel Tupitsyn <[email protected]>
AuthorDate: Mon May 30 22:46:19 2022 +0300

    wip cleanup
---
 .../apache/ignite/client/fakes/FakeSession.java    | 34 ++++++++++------------
 1 file changed, 15 insertions(+), 19 deletions(-)

diff --git 
a/modules/client/src/test/java/org/apache/ignite/client/fakes/FakeSession.java 
b/modules/client/src/test/java/org/apache/ignite/client/fakes/FakeSession.java
index 613bce94e..cabae6555 100644
--- 
a/modules/client/src/test/java/org/apache/ignite/client/fakes/FakeSession.java
+++ 
b/modules/client/src/test/java/org/apache/ignite/client/fakes/FakeSession.java
@@ -72,21 +72,19 @@ public class FakeSession implements Session {
     /** {@inheritDoc} */
     @Override
     public ResultSet execute(@Nullable Transaction transaction, String query, 
@Nullable Object... arguments) {
-        // TODO: Wrap AsyncResultSet.
-        // return sync(executeAsync(transaction, query, arguments));
-        return null;
+        throw new UnsupportedOperationException();
     }
 
     /** {@inheritDoc} */
     @Override
     public ResultSet execute(@Nullable Transaction transaction, Statement 
statement, @Nullable Object... arguments) {
-        return null;
+        throw new UnsupportedOperationException();
     }
 
     /** {@inheritDoc} */
     @Override
     public CompletableFuture<AsyncResultSet> executeAsync(@Nullable 
Transaction transaction, String query, @Nullable Object... arguments) {
-        return null;
+        throw new UnsupportedOperationException();
     }
 
     /** {@inheritDoc} */
@@ -103,61 +101,61 @@ public class FakeSession implements Session {
     /** {@inheritDoc} */
     @Override
     public ReactiveResultSet executeReactive(@Nullable Transaction 
transaction, String query, @Nullable Object... arguments) {
-        return null;
+        throw new UnsupportedOperationException();
     }
 
     /** {@inheritDoc} */
     @Override
     public ReactiveResultSet executeReactive(@Nullable Transaction 
transaction, Statement statement, @Nullable Object... arguments) {
-        return null;
+        throw new UnsupportedOperationException();
     }
 
     /** {@inheritDoc} */
     @Override
     public int[] executeBatch(@Nullable Transaction transaction, String 
dmlQuery, BatchedArguments batch) {
-        return new int[0];
+        throw new UnsupportedOperationException();
     }
 
     /** {@inheritDoc} */
     @Override
     public int[] executeBatch(@Nullable Transaction transaction, Statement 
dmlStatement, BatchedArguments batch) {
-        return new int[0];
+        throw new UnsupportedOperationException();
     }
 
     /** {@inheritDoc} */
     @Override
     public CompletableFuture<int[]> executeBatchAsync(@Nullable Transaction 
transaction, String query, BatchedArguments batch) {
-        return null;
+        throw new UnsupportedOperationException();
     }
 
     /** {@inheritDoc} */
     @Override
     public CompletableFuture<int[]> executeBatchAsync(@Nullable Transaction 
transaction, Statement statement, BatchedArguments batch) {
-        return null;
+        throw new UnsupportedOperationException();
     }
 
     /** {@inheritDoc} */
     @Override
     public Publisher<Integer> executeBatchReactive(@Nullable Transaction 
transaction, String query, BatchedArguments batch) {
-        return null;
+        throw new UnsupportedOperationException();
     }
 
     /** {@inheritDoc} */
     @Override
     public Publisher<Integer> executeBatchReactive(@Nullable Transaction 
transaction, Statement statement, BatchedArguments batch) {
-        return null;
+        throw new UnsupportedOperationException();
     }
 
     /** {@inheritDoc} */
     @Override
     public void executeScript(String query, @Nullable Object... arguments) {
-
+        throw new UnsupportedOperationException();
     }
 
     /** {@inheritDoc} */
     @Override
     public CompletableFuture<Void> executeScriptAsync(String query, @Nullable 
Object... arguments) {
-        return null;
+        throw new UnsupportedOperationException();
     }
 
     /** {@inheritDoc} */
@@ -193,15 +191,13 @@ public class FakeSession implements Session {
     /** {@inheritDoc} */
     @Override
     public CompletableFuture<Void> closeAsync() {
-        // TODO: Cancel/close all active futures.
-        return null;
+        return CompletableFuture.completedFuture(null);
     }
 
     /** {@inheritDoc} */
     @Override
     public Publisher<Void> closeReactive() {
-        // TODO: Future to Publisher.
-        return null;
+        throw new UnsupportedOperationException();
     }
 
     /** {@inheritDoc} */

Reply via email to