This is an automated email from the ASF dual-hosted git repository.
nizhikov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new d8ae1ee9069 IGNITE-27734 Generate serdes code for SingleFieldDto
(#12691)
d8ae1ee9069 is described below
commit d8ae1ee9069d963e8d921c25ccbbba1a4eac655d
Author: Nikolay <[email protected]>
AuthorDate: Wed Feb 4 16:40:36 2026 +0300
IGNITE-27734 Generate serdes code for SingleFieldDto (#12691)
---
.../idto/IgniteDataTransferObjectProcessor.java | 10 +--
.../management/cache/IndexForceRebuildTaskRes.java | 18 ------
.../cache/IndexRebuildStatusInfoContainer.java | 20 ------
.../encryption/CacheGroupEncryptionTask.java | 20 +-----
.../encryption/EncryptionKeyIdsTask.java | 26 +++-----
.../encryption/ReencryptionResumeTask.java | 8 ++-
.../encryption/ReencryptionStatusTask.java | 31 ++++-----
.../encryption/ReencryptionSuspendTask.java | 26 +++-----
.../ignite/internal/management/tx/TxInfo.java | 74 ++++------------------
.../ignite/internal/visor/VisorTaskArgument.java | 24 +------
.../ignite/internal/visor/VisorTaskResult.java | 19 +-----
11 files changed, 61 insertions(+), 215 deletions(-)
diff --git
a/modules/codegen2/src/main/java/org/apache/ignite/internal/idto/IgniteDataTransferObjectProcessor.java
b/modules/codegen2/src/main/java/org/apache/ignite/internal/idto/IgniteDataTransferObjectProcessor.java
index 5c830f1781d..e18a2e048df 100644
---
a/modules/codegen2/src/main/java/org/apache/ignite/internal/idto/IgniteDataTransferObjectProcessor.java
+++
b/modules/codegen2/src/main/java/org/apache/ignite/internal/idto/IgniteDataTransferObjectProcessor.java
@@ -75,15 +75,7 @@ public class IgniteDataTransferObjectProcessor extends
AbstractProcessor {
"org.apache.ignite.internal.processors.cache.CacheMetricsSnapshot",
"org.apache.ignite.internal.commandline.cache.check_indexes_inline_size.CheckIndexInlineSizesResult",
"org.apache.ignite.internal.management.cache.ContentionJobResult",
-
"org.apache.ignite.internal.processors.metastorage.persistence.DistributedMetaStorageHistoryItem",
- "org.apache.ignite.internal.management.tx.TxInfo",
-
"org.apache.ignite.internal.management.encryption.ReencryptionSuspendTask.ReencryptionSuspendResumeJobResult",
-
"org.apache.ignite.internal.management.encryption.ReencryptionStatusTask.ReencryptionStatusResult",
-
"org.apache.ignite.internal.management.encryption.EncryptionKeyIdsTask.EncryptionKeyIdsResult",
- "org.apache.ignite.internal.management.cache.IndexForceRebuildTaskRes",
-
"org.apache.ignite.internal.management.cache.IndexRebuildStatusInfoContainer",
- "org.apache.ignite.internal.visor.VisorTaskResult",
- "org.apache.ignite.internal.visor.VisorTaskArgument"
+
"org.apache.ignite.internal.processors.metastorage.persistence.DistributedMetaStorageHistoryItem"
);
/**
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/management/cache/IndexForceRebuildTaskRes.java
b/modules/core/src/main/java/org/apache/ignite/internal/management/cache/IndexForceRebuildTaskRes.java
index 98bb2e5da21..80beed3ccad 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/management/cache/IndexForceRebuildTaskRes.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/management/cache/IndexForceRebuildTaskRes.java
@@ -17,12 +17,8 @@
package org.apache.ignite.internal.management.cache;
-import java.io.IOException;
-import java.io.ObjectInput;
-import java.io.ObjectOutput;
import java.util.Set;
import org.apache.ignite.internal.dto.IgniteDataTransferObject;
-import org.apache.ignite.internal.util.typedef.internal.U;
/**
* Result of {@link IndexForceRebuildTask}.
@@ -58,20 +54,6 @@ public class IndexForceRebuildTaskRes extends
IgniteDataTransferObject {
this.notFoundCacheNames = notFoundCacheNames;
}
- /** {@inheritDoc} */
- @Override protected void writeExternalData(ObjectOutput out) throws
IOException {
- U.writeCollection(out, cachesWithStartedRebuild);
- U.writeCollection(out, cachesWithRebuildInProgress);
- U.writeCollection(out, notFoundCacheNames);
- }
-
- /** {@inheritDoc} */
- @Override protected void readExternalData(ObjectInput in) throws
IOException, ClassNotFoundException {
- cachesWithStartedRebuild = U.readSet(in);
- cachesWithRebuildInProgress = U.readSet(in);
- notFoundCacheNames = U.readSet(in);
- }
-
/** */
public Set<IndexRebuildStatusInfoContainer> cachesWithStartedRebuild() {
return cachesWithStartedRebuild;
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/management/cache/IndexRebuildStatusInfoContainer.java
b/modules/core/src/main/java/org/apache/ignite/internal/management/cache/IndexRebuildStatusInfoContainer.java
index 89bf674ed15..ebd9d55520d 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/management/cache/IndexRebuildStatusInfoContainer.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/management/cache/IndexRebuildStatusInfoContainer.java
@@ -17,15 +17,11 @@
package org.apache.ignite.internal.management.cache;
-import java.io.IOException;
-import java.io.ObjectInput;
-import java.io.ObjectOutput;
import java.util.Comparator;
import org.apache.ignite.configuration.CacheConfiguration;
import org.apache.ignite.internal.dto.IgniteDataTransferObject;
import org.apache.ignite.internal.processors.cache.GridCacheContext;
import org.apache.ignite.internal.util.typedef.internal.S;
-import org.apache.ignite.internal.util.typedef.internal.U;
/**
* Container for index rebuild status info.
@@ -68,22 +64,6 @@ public class IndexRebuildStatusInfoContainer extends
IgniteDataTransferObject {
totalPartitionsCount = cctx.topology().localPartitionsNumber();
}
- /** {@inheritDoc} */
- @Override protected void writeExternalData(ObjectOutput out) throws
IOException {
- U.writeString(out, groupName);
- U.writeString(out, cacheName);
- out.writeInt(indexBuildPartitionsLeftCount);
- out.writeInt(totalPartitionsCount);
- }
-
- /** {@inheritDoc} */
- @Override protected void readExternalData(ObjectInput in) throws
IOException, ClassNotFoundException {
- groupName = U.readString(in);
- cacheName = U.readString(in);
- indexBuildPartitionsLeftCount = in.readInt();
- totalPartitionsCount = in.readInt();
- }
-
/** {@inheritDoc} */
@Override public boolean equals(Object o) {
if (!(o instanceof IndexRebuildStatusInfoContainer))
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/CacheGroupEncryptionTask.java
b/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/CacheGroupEncryptionTask.java
index 837b4b90621..285f290ce33 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/CacheGroupEncryptionTask.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/CacheGroupEncryptionTask.java
@@ -24,7 +24,6 @@ import java.util.UUID;
import org.apache.ignite.IgniteCheckedException;
import org.apache.ignite.IgniteException;
import org.apache.ignite.compute.ComputeJobResult;
-import org.apache.ignite.internal.dto.IgniteDataTransferObject;
import org.apache.ignite.internal.processors.cache.CacheGroupContext;
import org.apache.ignite.internal.processors.cache.IgniteInternalCache;
import org.apache.ignite.internal.util.typedef.internal.CU;
@@ -62,26 +61,11 @@ public abstract class CacheGroupEncryptionTask<T> extends
VisorMultiNodeTask<Enc
}
/** */
- public abstract static class SingleFieldDto<T> extends
IgniteDataTransferObject {
- /** Object value. */
- private T val;
-
+ public interface SingleFieldDto<T> {
/**
* @return Object value.
*/
- protected T value() {
- return val;
- }
-
- /**
- * @param val Data object.
- * @return {@code this} for chaining.
- */
- protected SingleFieldDto<T> value(T val) {
- this.val = val;
-
- return this;
- }
+ public T value();
}
/**
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/EncryptionKeyIdsTask.java
b/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/EncryptionKeyIdsTask.java
index de3b9fe2141..9759fb1012b 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/EncryptionKeyIdsTask.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/EncryptionKeyIdsTask.java
@@ -17,13 +17,10 @@
package org.apache.ignite.internal.management.encryption;
-import java.io.IOException;
-import java.io.ObjectInput;
-import java.io.ObjectOutput;
import java.util.List;
+import org.apache.ignite.internal.dto.IgniteDataTransferObject;
import org.apache.ignite.internal.processors.cache.CacheGroupContext;
import org.apache.ignite.internal.processors.task.GridInternal;
-import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.internal.visor.VisorJob;
import org.jetbrains.annotations.Nullable;
@@ -56,28 +53,25 @@ public class EncryptionKeyIdsTask extends
CacheGroupEncryptionTask<List<Integer>
/** {@inheritDoc} */
@Override protected SingleFieldDto<List<Integer>>
run0(CacheGroupContext grp) {
- return new
EncryptionKeyIdsResult().value(ignite.context().encryption().groupKeyIds(grp.groupId()));
+ EncryptionKeyIdsResult res = new EncryptionKeyIdsResult();
+
+ res.val = ignite.context().encryption().groupKeyIds(grp.groupId());
+
+ return res;
}
}
/** */
- protected static class EncryptionKeyIdsResult extends
SingleFieldDto<List<Integer>> {
+ public static class EncryptionKeyIdsResult extends
IgniteDataTransferObject implements SingleFieldDto<List<Integer>> {
/** Serial version uid. */
private static final long serialVersionUID = 0L;
/** */
- public EncryptionKeyIdsResult() {
- // No-op.
- }
-
- /** {@inheritDoc} */
- @Override protected void writeExternalData(ObjectOutput out) throws
IOException {
- U.writeCollection(out, value());
- }
+ List<Integer> val;
/** {@inheritDoc} */
- @Override protected void readExternalData(ObjectInput in) throws
IOException, ClassNotFoundException {
- value(U.readList(in));
+ @Override public List<Integer> value() {
+ return val;
}
}
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/ReencryptionResumeTask.java
b/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/ReencryptionResumeTask.java
index 87136ee150d..8cce51e2f54 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/ReencryptionResumeTask.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/ReencryptionResumeTask.java
@@ -18,6 +18,7 @@
package org.apache.ignite.internal.management.encryption;
import org.apache.ignite.IgniteCheckedException;
+import
org.apache.ignite.internal.management.encryption.ReencryptionSuspendTask.ReencryptionSuspendResumeJobResult;
import org.apache.ignite.internal.processors.cache.CacheGroupContext;
import org.apache.ignite.internal.processors.task.GridInternal;
import org.apache.ignite.internal.visor.VisorJob;
@@ -52,8 +53,11 @@ public class ReencryptionResumeTask extends
CacheGroupEncryptionTask<Boolean> {
/** {@inheritDoc} */
@Override protected SingleFieldDto<Boolean> run0(CacheGroupContext
grp) throws IgniteCheckedException {
- return new
ReencryptionSuspendTask.ReencryptionSuspendResumeJobResult().value(
-
ignite.context().encryption().resumeReencryption(grp.groupId()));
+ ReencryptionSuspendResumeJobResult res = new
ReencryptionSuspendResumeJobResult();
+
+ res.val =
ignite.context().encryption().resumeReencryption(grp.groupId());
+
+ return res;
}
}
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/ReencryptionStatusTask.java
b/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/ReencryptionStatusTask.java
index e72ec7c3e5b..805f19a44d9 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/ReencryptionStatusTask.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/ReencryptionStatusTask.java
@@ -17,9 +17,7 @@
package org.apache.ignite.internal.management.encryption;
-import java.io.IOException;
-import java.io.ObjectInput;
-import java.io.ObjectOutput;
+import org.apache.ignite.internal.dto.IgniteDataTransferObject;
import org.apache.ignite.internal.processors.cache.CacheGroupContext;
import org.apache.ignite.internal.processors.task.GridInternal;
import org.apache.ignite.internal.visor.VisorJob;
@@ -54,35 +52,32 @@ public class ReencryptionStatusTask extends
CacheGroupEncryptionTask<Long> {
/** {@inheritDoc} */
@Override protected SingleFieldDto<Long> run0(CacheGroupContext grp) {
- long res;
+ long val;
if
(!ignite.context().encryption().reencryptionInProgress(grp.groupId()))
- res = -1;
+ val = -1;
else
- res =
ignite.context().encryption().getBytesLeftForReencryption(grp.groupId());
+ val =
ignite.context().encryption().getBytesLeftForReencryption(grp.groupId());
- return new ReencryptionStatusResult().value(res);
+ ReencryptionStatusResult res = new ReencryptionStatusResult();
+
+ res.val = val;
+
+ return res;
}
}
/** */
- protected static class ReencryptionStatusResult extends
SingleFieldDto<Long> {
+ public static class ReencryptionStatusResult extends
IgniteDataTransferObject implements SingleFieldDto<Long> {
/** Serial version uid. */
private static final long serialVersionUID = 0L;
/** */
- public ReencryptionStatusResult() {
- // No-op.
- }
-
- /** {@inheritDoc} */
- @Override protected void writeExternalData(ObjectOutput out) throws
IOException {
- out.writeLong(value());
- }
+ Long val;
/** {@inheritDoc} */
- @Override protected void readExternalData(ObjectInput in) throws
IOException, ClassNotFoundException {
- value(in.readLong());
+ @Override public Long value() {
+ return val;
}
}
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/ReencryptionSuspendTask.java
b/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/ReencryptionSuspendTask.java
index bec721205ce..47a329e6af7 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/ReencryptionSuspendTask.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/management/encryption/ReencryptionSuspendTask.java
@@ -17,10 +17,8 @@
package org.apache.ignite.internal.management.encryption;
-import java.io.IOException;
-import java.io.ObjectInput;
-import java.io.ObjectOutput;
import org.apache.ignite.IgniteCheckedException;
+import org.apache.ignite.internal.dto.IgniteDataTransferObject;
import org.apache.ignite.internal.processors.cache.CacheGroupContext;
import org.apache.ignite.internal.processors.task.GridInternal;
import org.apache.ignite.internal.visor.VisorJob;
@@ -55,29 +53,25 @@ public class ReencryptionSuspendTask extends
CacheGroupEncryptionTask<Boolean> {
/** {@inheritDoc} */
@Override protected SingleFieldDto<Boolean> run0(CacheGroupContext
grp) throws IgniteCheckedException {
- return new ReencryptionSuspendResumeJobResult().value(
-
ignite.context().encryption().suspendReencryption(grp.groupId()));
+ ReencryptionSuspendResumeJobResult res = new
ReencryptionSuspendResumeJobResult();
+
+ res.val =
ignite.context().encryption().suspendReencryption(grp.groupId());
+
+ return res;
}
}
/** */
- protected static class ReencryptionSuspendResumeJobResult extends
SingleFieldDto<Boolean> {
+ public static class ReencryptionSuspendResumeJobResult extends
IgniteDataTransferObject implements SingleFieldDto<Boolean> {
/** Serial version uid. */
private static final long serialVersionUID = 0L;
/** */
- public ReencryptionSuspendResumeJobResult() {
- // No-op.
- }
-
- /** {@inheritDoc} */
- @Override protected void writeExternalData(ObjectOutput out) throws
IOException {
- out.writeBoolean(value());
- }
+ Boolean val;
/** {@inheritDoc} */
- @Override protected void readExternalData(ObjectInput in) throws
IOException, ClassNotFoundException {
- value(in.readBoolean());
+ @Override public Boolean value() {
+ return val;
}
}
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/management/tx/TxInfo.java
b/modules/core/src/main/java/org/apache/ignite/internal/management/tx/TxInfo.java
index d2ca6d25b0b..53c66f79b83 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/management/tx/TxInfo.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/management/tx/TxInfo.java
@@ -17,9 +17,6 @@
package org.apache.ignite.internal.management.tx;
-import java.io.IOException;
-import java.io.ObjectInput;
-import java.io.ObjectOutput;
import java.time.Instant;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
@@ -48,48 +45,48 @@ public class TxInfo extends IgniteDataTransferObject {
private static DateTimeFormatter dateTimeFormatter =
DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS");
/** */
- private IgniteUuid xid;
+ IgniteUuid xid;
/**
* Transaction start time.
*/
- private long startTime;
+ long startTime;
/** */
- private long duration;
+ long duration;
/** */
- private TransactionIsolation isolation;
+ TransactionIsolation isolation;
/** */
- private TransactionConcurrency concurrency;
+ TransactionConcurrency concurrency;
/** */
- private long timeout;
+ long timeout;
/** */
- private String lb;
+ String lb;
/** */
- private Collection<UUID> primaryNodes;
+ Collection<UUID> primaryNodes;
/** */
- private TransactionState state;
+ TransactionState state;
/** */
- private int size;
+ int size;
/** */
- private IgniteUuid nearXid;
+ IgniteUuid nearXid;
/** */
- private Collection<UUID> masterNodeIds;
+ Collection<UUID> masterNodeIds;
/** */
- private AffinityTopologyVersion topVer;
+ AffinityTopologyVersion topVer;
/** Tx verbose info. */
- private TxVerboseInfo txVerboseInfo;
+ TxVerboseInfo txVerboseInfo;
/**
* Default constructor.
@@ -219,49 +216,6 @@ public class TxInfo extends IgniteDataTransferObject {
return txVerboseInfo;
}
- /** {@inheritDoc} */
- @Override protected void writeExternalData(ObjectOutput out) throws
IOException {
- U.writeIgniteUuid(out, xid);
- out.writeLong(duration);
- U.writeEnum(out, isolation);
- U.writeEnum(out, concurrency);
- out.writeLong(timeout);
- U.writeString(out, lb);
- U.writeCollection(out, primaryNodes);
- U.writeEnum(out, state);
- out.writeInt(size);
- U.writeIgniteUuid(out, nearXid);
- U.writeCollection(out, masterNodeIds);
- out.writeLong(startTime);
- out.writeLong(topVer == null ? -1 : topVer.topologyVersion());
- out.writeInt(topVer == null ? -1 : topVer.minorTopologyVersion());
- out.writeObject(txVerboseInfo);
- }
-
- /** {@inheritDoc} */
- @Override protected void readExternalData(ObjectInput in) throws
IOException, ClassNotFoundException {
- xid = U.readIgniteUuid(in);
- duration = in.readLong();
- isolation = TransactionIsolation.fromOrdinal(in.readByte());
- concurrency = TransactionConcurrency.fromOrdinal(in.readByte());
- timeout = in.readLong();
- lb = U.readString(in);
- primaryNodes = U.readCollection(in);
- state = TransactionState.fromOrdinal(in.readByte());
- size = in.readInt();
- nearXid = U.readIgniteUuid(in);
- masterNodeIds = U.readCollection(in);
- startTime = in.readLong();
-
- long topVer = in.readLong();
- int minorTopVer = in.readInt();
-
- if (topVer != -1)
- this.topVer = new AffinityTopologyVersion(topVer, minorTopVer);
-
- txVerboseInfo = (TxVerboseInfo)in.readObject();
- }
-
/**
* Get tx info as user string.
*
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/visor/VisorTaskArgument.java
b/modules/core/src/main/java/org/apache/ignite/internal/visor/VisorTaskArgument.java
index 4baa71d1ff1..7208d589544 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/visor/VisorTaskArgument.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/visor/VisorTaskArgument.java
@@ -17,16 +17,12 @@
package org.apache.ignite.internal.visor;
-import java.io.IOException;
-import java.io.ObjectInput;
-import java.io.ObjectOutput;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
import java.util.UUID;
import org.apache.ignite.internal.dto.IgniteDataTransferObject;
import org.apache.ignite.internal.util.typedef.internal.S;
-import org.apache.ignite.internal.util.typedef.internal.U;
/**
* Visor tasks argument.
@@ -36,13 +32,13 @@ public class VisorTaskArgument<A> extends
IgniteDataTransferObject {
private static final long serialVersionUID = 0L;
/** Node IDs task should be mapped to. */
- private List<UUID> nodes;
+ List<UUID> nodes;
/** Task argument. */
- private A arg;
+ A arg;
/** Debug flag. */
- private boolean debug;
+ boolean debug;
/**
* Default constructor.
@@ -119,20 +115,6 @@ public class VisorTaskArgument<A> extends
IgniteDataTransferObject {
return debug;
}
- /** {@inheritDoc} */
- @Override protected void writeExternalData(ObjectOutput out) throws
IOException {
- U.writeCollection(out, nodes);
- out.writeObject(arg);
- out.writeBoolean(debug);
- }
-
- /** {@inheritDoc} */
- @Override protected void readExternalData(ObjectInput in) throws
IOException, ClassNotFoundException {
- nodes = U.readList(in);
- arg = (A)in.readObject();
- debug = in.readBoolean();
- }
-
/** {@inheritDoc} */
@Override public String toString() {
return S.toString(VisorTaskArgument.class, this);
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/visor/VisorTaskResult.java
b/modules/core/src/main/java/org/apache/ignite/internal/visor/VisorTaskResult.java
index 21271269c82..c1cbd82f473 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/visor/VisorTaskResult.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/visor/VisorTaskResult.java
@@ -17,9 +17,6 @@
package org.apache.ignite.internal.visor;
-import java.io.IOException;
-import java.io.ObjectInput;
-import java.io.ObjectOutput;
import org.apache.ignite.internal.dto.IgniteDataTransferObject;
import org.jetbrains.annotations.Nullable;
@@ -31,10 +28,10 @@ public class VisorTaskResult<R> extends
IgniteDataTransferObject {
private static final long serialVersionUID = 0L;
/** Task result. */
- private @Nullable R res;
+ @Nullable R res;
/** Error. */
- private @Nullable Exception err;
+ @Nullable Exception err;
/** */
public VisorTaskResult() {
@@ -60,16 +57,4 @@ public class VisorTaskResult<R> extends
IgniteDataTransferObject {
return res;
}
-
- /** {@inheritDoc} */
- @Override protected void writeExternalData(ObjectOutput out) throws
IOException {
- out.writeObject(res);
- out.writeObject(err);
- }
-
- /** {@inheritDoc} */
- @Override protected void readExternalData(ObjectInput in) throws
IOException, ClassNotFoundException {
- res = (R)in.readObject();
- err = (Exception)in.readObject();
- }
}
