This is an automated email from the ASF dual-hosted git repository.
sk0x50 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 0c68cbe3f0 IGNITE-17883 Removed not implemented 'invoke' functionality
(#2090)
0c68cbe3f0 is described below
commit 0c68cbe3f016e508bd9d53ce5320c88acba1acff
Author: Slava Koptilin <slava.kopti...@gmail.com>
AuthorDate: Tue May 23 10:17:53 2023 +0300
IGNITE-17883 Removed not implemented 'invoke' functionality (#2090)
---
.../org/apache/ignite/table/InvocationContext.java | 70 ----------------------
.../org/apache/ignite/table/InvokeProcessor.java | 47 ---------------
.../ignite/table/InvokeProcessorException.java | 38 ------------
.../java/org/apache/ignite/table/KeyValueView.java | 65 --------------------
.../java/org/apache/ignite/table/RecordView.java | 48 ---------------
.../client/table/ClientKeyValueBinaryView.java | 46 --------------
.../internal/client/table/ClientKeyValueView.java | 46 --------------
.../client/table/ClientRecordBinaryView.java | 39 ------------
.../internal/client/table/ClientRecordView.java | 39 ------------
.../internal/table/KeyValueBinaryViewImpl.java | 46 --------------
.../ignite/internal/table/KeyValueViewImpl.java | 46 --------------
.../internal/table/RecordBinaryViewImpl.java | 43 -------------
.../ignite/internal/table/RecordViewImpl.java | 39 ------------
13 files changed, 612 deletions(-)
diff --git
a/modules/api/src/main/java/org/apache/ignite/table/InvocationContext.java
b/modules/api/src/main/java/org/apache/ignite/table/InvocationContext.java
deleted file mode 100644
index dfd1743905..0000000000
--- a/modules/api/src/main/java/org/apache/ignite/table/InvocationContext.java
+++ /dev/null
@@ -1,70 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.table;
-
-/**
- * Invocation context provides access for the invoke operation's parameters, a
method to set a new value for the key.
- *
- * <p>InvokeProcessor executes atomically under lock, which makes triggering
'live-schema' upgrade impossible within the
- * invoke operation. Any attempt to update the row leading to schema change
results in {@link InvokeProcessorException}.
- *
- * <p>New value MUST be compliant with the current schema version.
- *
- * @param <K> Target object type.
- * @param <V> Value object type.
- * @see InvokeProcessor
- */
-public interface InvocationContext<K, V> {
- /**
- * Returns user-provided arguments for the invoke operation.
- *
- * @return Agruments for invocation processor.
- */
- Object[] args();
-
- /**
- * Returns a user-provided object for the invoke call to run the invoke
processor against a specified row.
- *
- * <p>Depending on the Table view the invoke operation is called on, the
returned value is either a value object,
- * a record object, or a tuple with value fields set.
- *
- * @return Object the target row is associated with.
- */
- K key();
-
- /**
- * Returns the current value object for the target row.
- *
- * <p>Depending on the Table view the invoke operation is called on, the
returning value is either a value object,
- * a record object, a tuple with value fields set, or {@code null} for
non-existent row.
- *
- * @return Current value of the target row or {@code null} if the value
associated with the key does not exist.
- */
- V value();
-
- /**
- * Sets a new value object for the target row.
- *
- * <p>Depending on the Table view the invoke operation is called on, a new
value can be either a value object,
- * a record object, a tuple with value fields set, or {@code null} for
removal.
- *
- * @param val Value object to set.
- * @throws InvokeProcessorException if new value is not compliant with the
current schema.
- */
- void value(V val);
-}
diff --git
a/modules/api/src/main/java/org/apache/ignite/table/InvokeProcessor.java
b/modules/api/src/main/java/org/apache/ignite/table/InvokeProcessor.java
deleted file mode 100644
index 5d5570800e..0000000000
--- a/modules/api/src/main/java/org/apache/ignite/table/InvokeProcessor.java
+++ /dev/null
@@ -1,47 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.table;
-
-import java.io.Serializable;
-
-/**
- * Invoke processor interface provides an API for running code on server side
against a table record associated with
- * the specified key.
- *
- * <p>For non-binary projections, the row is deserialized to user object(s)
before the invocation, and is serialized
- * back if a new value is set via {@linkplain InvocationContext#value(Object)}.
- *
- * <p>The invoke operation arguments, along with the invoke operation result
classes,
- * MUST be serializable as they can be transferred over network.
- *
- * @param <K> Key object type.
- * @param <V> Value type.
- * @param <R> Processor result type.
- * @apiNote Distributed deployment MUST be used for processor code load,
instead of loading from the classpath,
- * to guarantee the same code version in the grid.
- */
-public interface InvokeProcessor<K, V, R extends Serializable> extends
Serializable {
- /**
- * Processes a table record and returns a result.
- *
- * @param ctx Invocation context.
- * @return Invoke processor result.
- * @throws InvokeProcessorException If failed during data processing.
- */
- R process(InvocationContext<K, V> ctx) throws InvokeProcessorException;
-}
diff --git
a/modules/api/src/main/java/org/apache/ignite/table/InvokeProcessorException.java
b/modules/api/src/main/java/org/apache/ignite/table/InvokeProcessorException.java
deleted file mode 100644
index c96981b4ef..0000000000
---
a/modules/api/src/main/java/org/apache/ignite/table/InvokeProcessorException.java
+++ /dev/null
@@ -1,38 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.table;
-
-import java.util.UUID;
-import org.apache.ignite.lang.IgniteException;
-
-/**
- * InvokeProcessor invocation exception.
- */
-public class InvokeProcessorException extends IgniteException {
- /**
- * Creates a new exception with the given trace id, error code, detail
message and cause.
- *
- * @param traceId Unique identifier of this exception.
- * @param code Full error code.
- * @param message Detail message.
- * @param cause Optional nested exception (can be {@code null}).
- */
- public InvokeProcessorException(UUID traceId, int code, String message,
Throwable cause) {
- super(traceId, code, message, cause);
- }
-}
diff --git
a/modules/api/src/main/java/org/apache/ignite/table/KeyValueView.java
b/modules/api/src/main/java/org/apache/ignite/table/KeyValueView.java
index b02efd8ce2..6e6658963c 100644
--- a/modules/api/src/main/java/org/apache/ignite/table/KeyValueView.java
+++ b/modules/api/src/main/java/org/apache/ignite/table/KeyValueView.java
@@ -17,7 +17,6 @@
package org.apache.ignite.table;
-import java.io.Serializable;
import java.util.Collection;
import java.util.Map;
import java.util.concurrent.CompletableFuture;
@@ -492,68 +491,4 @@ public interface KeyValueView<K, V> {
* @see #getAndReplace(Transaction, Object, Object)
*/
@NotNull CompletableFuture<NullableValue<V>>
getNullableAndReplaceAsync(@Nullable Transaction tx, @NotNull K key, V val);
-
- /**
- * Executes the invoke processor code against a value associated with the
provided key.
- *
- * @param tx Transaction or {@code null} to auto-commit.
- * @param key Key associated with the value that the invoke processor will
be applied to. The key cannot be {@code null}.
- * @param proc Invocation processor.
- * @param args Optional invoke processor arguments.
- * @param <R> Invoke processor result type.
- * @return Result of the processing.
- * @see InvokeProcessor
- */
- <R extends Serializable> R invoke(@Nullable Transaction tx, @NotNull K
key, InvokeProcessor<K, V, R> proc, Serializable... args);
-
- /**
- * Asynchronously executes the invoke processor code against a value
associated with the provided key.
- *
- * @param tx Transaction or {@code null} to auto-commit.
- * @param key Key associated with the value that the invoke processor will
be applied to. The key cannot be {@code null}.
- * @param proc Invocation processor.
- * @param args Optional invoke processor arguments.
- * @param <R> Invoke processor result type.
- * @return Future that represents the pending completion of the operation.
- * @see InvokeProcessor
- */
- @NotNull <R extends Serializable> CompletableFuture<R> invokeAsync(
- @Nullable Transaction tx,
- @NotNull K key,
- InvokeProcessor<K, V, R> proc,
- Serializable... args);
-
- /**
- * Executes the invoke processor code against values associated with the
provided keys.
- *
- * @param tx Transaction or {@code null} to auto-commit.
- * @param <R> Invoke processor result type.
- * @param keys Ordered collection of keys whose values should be
processed. The keys cannot be {@code null}.
- * @param proc Invocation processor.
- * @param args Optional invoke processor arguments.
- * @return Results of the processing.
- * @see InvokeProcessor
- */
- <R extends Serializable> Map<K, R> invokeAll(
- @Nullable Transaction tx,
- @NotNull Collection<K> keys,
- InvokeProcessor<K, V, R> proc,
- Serializable... args);
-
- /**
- * Asynchronously executes the invoke processor code against values
associated with the provided keys.
- *
- * @param tx Transaction or {@code null} to auto-commit.
- * @param <R> Invoke processor result type.
- * @param keys Ordered collection of keys whose values should be
processed. The keys cannot be {@code null}.
- * @param proc Invocation processor.
- * @param args Optional invoke processor arguments.
- * @return Future that represents the pending completion of the operation.
- * @see InvokeProcessor
- */
- @NotNull <R extends Serializable> CompletableFuture<Map<K, R>>
invokeAllAsync(
- @Nullable Transaction tx,
- @NotNull Collection<K> keys,
- InvokeProcessor<K, V, R> proc,
- Serializable... args);
}
diff --git a/modules/api/src/main/java/org/apache/ignite/table/RecordView.java
b/modules/api/src/main/java/org/apache/ignite/table/RecordView.java
index e963177e27..0a3fcae9d1 100644
--- a/modules/api/src/main/java/org/apache/ignite/table/RecordView.java
+++ b/modules/api/src/main/java/org/apache/ignite/table/RecordView.java
@@ -17,9 +17,7 @@
package org.apache.ignite.table;
-import java.io.Serializable;
import java.util.Collection;
-import java.util.Map;
import java.util.concurrent.CompletableFuture;
import org.apache.ignite.tx.Transaction;
import org.jetbrains.annotations.NotNull;
@@ -304,50 +302,4 @@ public interface RecordView<R> {
* @return Future that represents the pending completion of the operation.
*/
@NotNull CompletableFuture<Collection<R>> deleteAllExactAsync(@Nullable
Transaction tx, @NotNull Collection<R> recs);
-
- /**
- * Executes the InvokeProcessor code against a record with the same key
column values as the given one.
- *
- * @param tx Transaction or {@code null} to auto-commit.
- * @param keyRec Record with the key columns set. The record cannot be
{@code null}.
- * @param proc Invoke processor.
- * @param <T> InvokeProcessor result type.
- * @return Results of the processing.
- */
- <T extends Serializable> T invoke(@Nullable Transaction tx, @NotNull R
keyRec, InvokeProcessor<R, R, T> proc);
-
- /**
- * Asynchronously executes the InvokeProcessor code against a record with
the same key columns values as the given one.
- *
- * @param tx Transaction or {@code null} to auto-commit.
- * @param keyRec A record with the key columns set. The record cannot be
{@code null}.
- * @param proc Invoke processor.
- * @param <T> InvokeProcessor result type.
- * @return Future that represents the pending completion of the operation.
- */
- @NotNull <T extends Serializable> CompletableFuture<T>
invokeAsync(@Nullable Transaction tx, @NotNull R keyRec,
- InvokeProcessor<R, R, T> proc);
-
- /**
- * Executes the InvokeProcessor code against records with the same key
column values as the given ones.
- *
- * @param tx Transaction or {@code null} to auto-commit.
- * @param keyRecs Records with the key columns set. The records cannot be
{@code null}.
- * @param proc Invoke processor.
- * @param <T> InvokeProcessor result type.
- * @return Results of the processing.
- */
- <T extends Serializable> Map<R, T> invokeAll(@Nullable Transaction tx,
@NotNull Collection<R> keyRecs, InvokeProcessor<R, R, T> proc);
-
- /**
- * Asynchronously executes the InvokeProcessor code against records with
the same key columns values as the given ones.
- *
- * @param tx Transaction or {@code null} to auto-commit.
- * @param keyRecs Records with the key columns set. The records cannot be
{@code null}.
- * @param proc Invoke processor.
- * @param <T> InvokeProcessor result type.
- * @return Results of the processing.
- */
- @NotNull <T extends Serializable> CompletableFuture<Map<R, T>>
invokeAllAsync(@Nullable Transaction tx, @NotNull Collection<R> keyRecs,
- InvokeProcessor<R, R, T> proc);
}
diff --git
a/modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientKeyValueBinaryView.java
b/modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientKeyValueBinaryView.java
index b678395163..9d4fea6dca 100644
---
a/modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientKeyValueBinaryView.java
+++
b/modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientKeyValueBinaryView.java
@@ -19,7 +19,6 @@ package org.apache.ignite.internal.client.table;
import static org.apache.ignite.internal.client.ClientUtils.sync;
-import java.io.Serializable;
import java.util.Collection;
import java.util.Collections;
import java.util.Map;
@@ -29,7 +28,6 @@ import
org.apache.ignite.internal.client.proto.ClientMessageUnpacker;
import org.apache.ignite.internal.client.proto.ClientOp;
import org.apache.ignite.internal.util.IgniteUtils;
import org.apache.ignite.lang.NullableValue;
-import org.apache.ignite.table.InvokeProcessor;
import org.apache.ignite.table.KeyValueView;
import org.apache.ignite.table.Tuple;
import org.apache.ignite.tx.Transaction;
@@ -437,48 +435,4 @@ public class ClientKeyValueBinaryView implements
KeyValueView<Tuple, Tuple> {
Tuple val) {
throw new UnsupportedOperationException("Binary view doesn't allow
null tuples.");
}
-
- /** {@inheritDoc} */
- @Override
- public <R extends Serializable> R invoke(
- @Nullable Transaction tx,
- @NotNull Tuple key,
- InvokeProcessor<Tuple, Tuple, R> proc,
- Serializable... args
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public @NotNull <R extends Serializable> CompletableFuture<R> invokeAsync(
- @Nullable Transaction tx,
- @NotNull Tuple key,
- InvokeProcessor<Tuple, Tuple, R> proc,
- Serializable... args
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public <R extends Serializable> Map<Tuple, R> invokeAll(
- @Nullable Transaction tx,
- @NotNull Collection<Tuple> keys,
- InvokeProcessor<Tuple, Tuple, R> proc,
- Serializable... args
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public @NotNull <R extends Serializable> CompletableFuture<Map<Tuple, R>>
invokeAllAsync(
- @Nullable Transaction tx,
- @NotNull Collection<Tuple> keys,
- InvokeProcessor<Tuple, Tuple, R> proc,
- Serializable... args
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
}
diff --git
a/modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientKeyValueView.java
b/modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientKeyValueView.java
index 6a3e1d16d7..317f639d98 100644
---
a/modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientKeyValueView.java
+++
b/modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientKeyValueView.java
@@ -21,7 +21,6 @@ import static
org.apache.ignite.internal.client.ClientUtils.sync;
import static org.apache.ignite.internal.client.table.ClientTable.writeTx;
import static org.apache.ignite.lang.ErrorGroups.Common.UNKNOWN_ERR;
-import java.io.Serializable;
import java.util.BitSet;
import java.util.Collection;
import java.util.Collections;
@@ -43,7 +42,6 @@ import org.apache.ignite.internal.marshaller.Marshaller;
import org.apache.ignite.internal.marshaller.MarshallerException;
import org.apache.ignite.lang.IgniteException;
import org.apache.ignite.lang.NullableValue;
-import org.apache.ignite.table.InvokeProcessor;
import org.apache.ignite.table.KeyValueView;
import org.apache.ignite.table.mapper.Mapper;
import org.apache.ignite.tx.Transaction;
@@ -426,50 +424,6 @@ public class ClientKeyValueView<K, V> implements
KeyValueView<K, V> {
throw new UnsupportedOperationException("Not implemented yet.");
}
- /** {@inheritDoc} */
- @Override
- public <R extends Serializable> R invoke(
- @Nullable Transaction tx,
- @NotNull K key,
- InvokeProcessor<K, V, R> proc,
- Serializable... args
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public @NotNull <R extends Serializable> CompletableFuture<R> invokeAsync(
- @Nullable Transaction tx,
- @NotNull K key,
- InvokeProcessor<K, V, R> proc,
- Serializable... args
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public <R extends Serializable> Map<K, R> invokeAll(
- @Nullable Transaction tx,
- @NotNull Collection<K> keys,
- InvokeProcessor<K, V, R> proc,
- Serializable... args
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public @NotNull <R extends Serializable> CompletableFuture<Map<K, R>>
invokeAllAsync(
- @Nullable Transaction tx,
- @NotNull Collection<K> keys,
- InvokeProcessor<K, V, R> proc,
- Serializable... args
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
private void writeKeyValue(ClientSchema s, PayloadOutputChannel w,
@Nullable Transaction tx, @NotNull K key, V val) {
writeSchemaAndTx(s, w, tx);
writeKeyValueRaw(s, w, key, val);
diff --git
a/modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientRecordBinaryView.java
b/modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientRecordBinaryView.java
index adc70dddaa..77a5c586c9 100644
---
a/modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientRecordBinaryView.java
+++
b/modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientRecordBinaryView.java
@@ -19,15 +19,12 @@ package org.apache.ignite.internal.client.table;
import static org.apache.ignite.internal.client.ClientUtils.sync;
-import java.io.Serializable;
import java.util.Collection;
import java.util.Collections;
-import java.util.Map;
import java.util.Objects;
import java.util.concurrent.CompletableFuture;
import org.apache.ignite.internal.client.proto.ClientMessageUnpacker;
import org.apache.ignite.internal.client.proto.ClientOp;
-import org.apache.ignite.table.InvokeProcessor;
import org.apache.ignite.table.RecordView;
import org.apache.ignite.table.Tuple;
import org.apache.ignite.tx.Transaction;
@@ -357,40 +354,4 @@ public class ClientRecordBinaryView implements
RecordView<Tuple> {
Collections.emptyList(),
ClientTupleSerializer.getPartitionAwarenessProvider(tx,
recs.iterator().next()));
}
-
- /** {@inheritDoc} */
- @Override
- public <T extends Serializable> T invoke(@Nullable Transaction tx,
@NotNull Tuple keyRec, InvokeProcessor<Tuple, Tuple, T> proc) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public @NotNull <T extends Serializable> CompletableFuture<T> invokeAsync(
- @Nullable Transaction tx,
- @NotNull Tuple keyRec,
- InvokeProcessor<Tuple, Tuple, T> proc
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public <T extends Serializable> Map<Tuple, T> invokeAll(
- @Nullable Transaction tx,
- @NotNull Collection<Tuple> keyRecs,
- InvokeProcessor<Tuple, Tuple, T> proc
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public @NotNull <T extends Serializable> CompletableFuture<Map<Tuple, T>>
invokeAllAsync(
- @Nullable Transaction tx,
- @NotNull Collection<Tuple> keyRecs,
- InvokeProcessor<Tuple, Tuple, T> proc
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
}
diff --git
a/modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientRecordView.java
b/modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientRecordView.java
index 6ba3346ccd..5dfddd8093 100644
---
a/modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientRecordView.java
+++
b/modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientRecordView.java
@@ -19,16 +19,13 @@ package org.apache.ignite.internal.client.table;
import static org.apache.ignite.internal.client.ClientUtils.sync;
-import java.io.Serializable;
import java.util.Collection;
import java.util.Collections;
-import java.util.Map;
import java.util.Objects;
import java.util.concurrent.CompletableFuture;
import org.apache.ignite.internal.client.proto.ClientMessageUnpacker;
import org.apache.ignite.internal.client.proto.ClientOp;
import org.apache.ignite.internal.client.proto.TuplePart;
-import org.apache.ignite.table.InvokeProcessor;
import org.apache.ignite.table.RecordView;
import org.apache.ignite.table.mapper.Mapper;
import org.apache.ignite.tx.Transaction;
@@ -354,40 +351,4 @@ public class ClientRecordView<R> implements RecordView<R> {
Collections.emptyList(),
ClientTupleSerializer.getPartitionAwarenessProvider(tx,
ser.mapper(), recs.iterator().next()));
}
-
- /** {@inheritDoc} */
- @Override
- public <T extends Serializable> T invoke(@Nullable Transaction tx,
@NotNull R keyRec, InvokeProcessor<R, R, T> proc) {
- throw new UnsupportedOperationException();
- }
-
- /** {@inheritDoc} */
- @Override
- public @NotNull <T extends Serializable> CompletableFuture<T> invokeAsync(
- @Nullable Transaction tx,
- @NotNull R keyRec,
- InvokeProcessor<R, R, T> proc
- ) {
- throw new UnsupportedOperationException();
- }
-
- /** {@inheritDoc} */
- @Override
- public <T extends Serializable> Map<R, T> invokeAll(
- @Nullable Transaction tx,
- @NotNull Collection<R> keyRecs,
- InvokeProcessor<R, R, T> proc
- ) {
- throw new UnsupportedOperationException();
- }
-
- /** {@inheritDoc} */
- @Override
- public @NotNull <T extends Serializable> CompletableFuture<Map<R, T>>
invokeAllAsync(
- @Nullable Transaction tx,
- @NotNull Collection<R> keyRecs,
- InvokeProcessor<R, R, T> proc
- ) {
- throw new UnsupportedOperationException();
- }
}
diff --git
a/modules/table/src/main/java/org/apache/ignite/internal/table/KeyValueBinaryViewImpl.java
b/modules/table/src/main/java/org/apache/ignite/internal/table/KeyValueBinaryViewImpl.java
index 55b8f47a93..b86512fa39 100644
---
a/modules/table/src/main/java/org/apache/ignite/internal/table/KeyValueBinaryViewImpl.java
+++
b/modules/table/src/main/java/org/apache/ignite/internal/table/KeyValueBinaryViewImpl.java
@@ -17,7 +17,6 @@
package org.apache.ignite.internal.table;
-import java.io.Serializable;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
@@ -35,7 +34,6 @@ import org.apache.ignite.internal.tx.InternalTransaction;
import org.apache.ignite.internal.util.IgniteUtils;
import org.apache.ignite.lang.IgniteException;
import org.apache.ignite.lang.NullableValue;
-import org.apache.ignite.table.InvokeProcessor;
import org.apache.ignite.table.KeyValueView;
import org.apache.ignite.table.Tuple;
import org.apache.ignite.tx.Transaction;
@@ -395,50 +393,6 @@ public class KeyValueBinaryViewImpl extends
AbstractTableView implements KeyValu
throw new UnsupportedOperationException("Binary view doesn't allow
null tuples.");
}
- /** {@inheritDoc} */
- @Override
- public <R extends Serializable> R invoke(
- @Nullable Transaction tx,
- @NotNull Tuple key,
- InvokeProcessor<Tuple, Tuple, R> proc,
- Serializable... args
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public @NotNull <R extends Serializable> CompletableFuture<R> invokeAsync(
- @Nullable Transaction tx,
- @NotNull Tuple key,
- InvokeProcessor<Tuple, Tuple, R> proc,
- Serializable... args
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public <R extends Serializable> Map<Tuple, R> invokeAll(
- @Nullable Transaction tx,
- @NotNull Collection<Tuple> keys,
- InvokeProcessor<Tuple, Tuple, R> proc,
- Serializable... args
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public @NotNull <R extends Serializable> CompletableFuture<Map<Tuple, R>>
invokeAllAsync(
- @Nullable Transaction tx,
- @NotNull Collection<Tuple> keys,
- InvokeProcessor<Tuple, Tuple, R> proc,
- Serializable... args
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
/**
* Marshal key-value pair to a row.
*
diff --git
a/modules/table/src/main/java/org/apache/ignite/internal/table/KeyValueViewImpl.java
b/modules/table/src/main/java/org/apache/ignite/internal/table/KeyValueViewImpl.java
index c965ebd33d..a0e8740924 100644
---
a/modules/table/src/main/java/org/apache/ignite/internal/table/KeyValueViewImpl.java
+++
b/modules/table/src/main/java/org/apache/ignite/internal/table/KeyValueViewImpl.java
@@ -17,7 +17,6 @@
package org.apache.ignite.internal.table;
-import java.io.Serializable;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
@@ -39,7 +38,6 @@ import org.apache.ignite.internal.util.IgniteUtils;
import org.apache.ignite.lang.IgniteException;
import org.apache.ignite.lang.NullableValue;
import org.apache.ignite.lang.UnexpectedNullValueException;
-import org.apache.ignite.table.InvokeProcessor;
import org.apache.ignite.table.KeyValueView;
import org.apache.ignite.table.mapper.Mapper;
import org.apache.ignite.tx.Transaction;
@@ -349,50 +347,6 @@ public class KeyValueViewImpl<K, V> extends
AbstractTableView implements KeyValu
.thenApply(r -> r == null ? null :
NullableValue.of(unmarshalNullableValue(r)));
}
- /** {@inheritDoc} */
- @Override
- public <R extends Serializable> R invoke(
- @Nullable Transaction tx,
- @NotNull K key,
- InvokeProcessor<K, V, R> proc,
- Serializable... args
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public @NotNull <R extends Serializable> CompletableFuture<R> invokeAsync(
- @Nullable Transaction tx,
- @NotNull K key,
- InvokeProcessor<K, V, R> proc,
- Serializable... args
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public <R extends Serializable> Map<K, R> invokeAll(
- @Nullable Transaction tx,
- @NotNull Collection<K> keys,
- InvokeProcessor<K, V, R> proc,
- Serializable... args
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public @NotNull <R extends Serializable> CompletableFuture<Map<K, R>>
invokeAllAsync(
- @Nullable Transaction tx,
- @NotNull Collection<K> keys,
- InvokeProcessor<K, V, R> proc,
- Serializable... args
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
/**
* Returns marshaller.
*
diff --git
a/modules/table/src/main/java/org/apache/ignite/internal/table/RecordBinaryViewImpl.java
b/modules/table/src/main/java/org/apache/ignite/internal/table/RecordBinaryViewImpl.java
index 8632f3fb48..15040843f2 100644
---
a/modules/table/src/main/java/org/apache/ignite/internal/table/RecordBinaryViewImpl.java
+++
b/modules/table/src/main/java/org/apache/ignite/internal/table/RecordBinaryViewImpl.java
@@ -17,11 +17,9 @@
package org.apache.ignite.internal.table;
-import java.io.Serializable;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
-import java.util.Map;
import java.util.Objects;
import java.util.concurrent.CompletableFuture;
import org.apache.ignite.internal.schema.BinaryRow;
@@ -32,7 +30,6 @@ import
org.apache.ignite.internal.schema.marshaller.TupleMarshallerImpl;
import org.apache.ignite.internal.schema.row.Row;
import org.apache.ignite.internal.tx.InternalTransaction;
import org.apache.ignite.lang.IgniteException;
-import org.apache.ignite.table.InvokeProcessor;
import org.apache.ignite.table.RecordView;
import org.apache.ignite.table.Tuple;
import org.apache.ignite.tx.Transaction;
@@ -290,46 +287,6 @@ public class RecordBinaryViewImpl extends
AbstractTableView implements RecordVie
return tbl.deleteAllExact(mapToBinary(recs, false),
(InternalTransaction) tx).thenApply(this::wrap);
}
- /** {@inheritDoc} */
- @Override
- public <T extends Serializable> T invoke(
- @Nullable Transaction tx,
- @NotNull Tuple keyRec,
- InvokeProcessor<Tuple, Tuple, T> proc
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public @NotNull <T extends Serializable> CompletableFuture<T> invokeAsync(
- @Nullable Transaction tx,
- @NotNull Tuple keyRec,
- InvokeProcessor<Tuple, Tuple, T> proc
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public <T extends Serializable> Map<Tuple, T> invokeAll(
- @Nullable Transaction tx,
- @NotNull Collection<Tuple> keyRecs,
- InvokeProcessor<Tuple, Tuple, T> proc
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public @NotNull <T extends Serializable> CompletableFuture<Map<Tuple, T>>
invokeAllAsync(
- @Nullable Transaction tx,
- @NotNull Collection<Tuple> keyRecs,
- InvokeProcessor<Tuple, Tuple, T> proc
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
/**
* Marshal a tuple to a row.
*
diff --git
a/modules/table/src/main/java/org/apache/ignite/internal/table/RecordViewImpl.java
b/modules/table/src/main/java/org/apache/ignite/internal/table/RecordViewImpl.java
index b6f2801998..95907e7329 100644
---
a/modules/table/src/main/java/org/apache/ignite/internal/table/RecordViewImpl.java
+++
b/modules/table/src/main/java/org/apache/ignite/internal/table/RecordViewImpl.java
@@ -17,12 +17,10 @@
package org.apache.ignite.internal.table;
-import java.io.Serializable;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
-import java.util.Map;
import java.util.Objects;
import java.util.concurrent.CompletableFuture;
import java.util.function.Function;
@@ -36,7 +34,6 @@ import
org.apache.ignite.internal.schema.marshaller.reflection.RecordMarshallerI
import org.apache.ignite.internal.schema.row.Row;
import org.apache.ignite.internal.tx.InternalTransaction;
import org.apache.ignite.lang.IgniteException;
-import org.apache.ignite.table.InvokeProcessor;
import org.apache.ignite.table.RecordView;
import org.apache.ignite.table.mapper.Mapper;
import org.apache.ignite.tx.Transaction;
@@ -277,42 +274,6 @@ public class RecordViewImpl<R> extends AbstractTableView
implements RecordView<R
return tbl.deleteAllExact(rows, (InternalTransaction)
tx).thenApply(this::unmarshal);
}
- /** {@inheritDoc} */
- @Override
- public <T extends Serializable> T invoke(@Nullable Transaction tx,
@NotNull R keyRec, InvokeProcessor<R, R, T> proc) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public @NotNull <T extends Serializable> CompletableFuture<T> invokeAsync(
- @Nullable Transaction tx,
- @NotNull R keyRec,
- InvokeProcessor<R, R, T> proc
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public <T extends Serializable> Map<R, T> invokeAll(
- @Nullable Transaction tx,
- @NotNull Collection<R> keyRecs,
- InvokeProcessor<R, R, T> proc
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
- /** {@inheritDoc} */
- @Override
- public @NotNull <T extends Serializable> CompletableFuture<Map<R, T>>
invokeAllAsync(
- @Nullable Transaction tx,
- @NotNull Collection<R> keyRecs,
- InvokeProcessor<R, R, T> proc
- ) {
- throw new UnsupportedOperationException("Not implemented yet.");
- }
-
/**
* Returns marshaller.
*
