This is an automated email from the ASF dual-hosted git repository.
apkhmv pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 2c3ce15a0d IGNITE-22233 Add zone replica listener (#3931)
add 5d65a0022a IGNITE-22646 Support marshallers in the Java Client for
Compute API (#4100)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/ignite/compute/ComputeJob.java | 18 +-
.../org/apache/ignite/compute/JobDescriptor.java | 26 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 7 +
.../ByteArrayMarshaller.java} | 18 +-
.../JavaSerializationByteArrayMarshalling.java} | 4 +-
.../Marshaler.java => marshalling/Marshaller.java} | 18 +-
.../MarshallingException.java | 4 +-
.../TupleMarshaller.java | 6 +-
...UnsupportedObjectTypeMarshallingException.java} | 12 +-
.../apache/ignite/table/ReceiverDescriptor.java | 12 +-
.../ByteArrayMarshallerTest.java} | 34 +--
.../client/proto/ClientBinaryTupleUtils.java | 8 +-
.../internal/client/proto/ClientMessagePacker.java | 8 +-
.../client/proto/StreamerReceiverSerializer.java | 6 +-
.../ClientComputeExecuteColocatedRequest.java | 4 +-
.../compute/ClientComputeExecuteRequest.java | 12 +-
.../internal/client/compute/ClientCompute.java | 36 +--
.../client/compute/ClientJobExecution.java | 6 +-
.../internal/client/table/ClientDataStreamer.java | 4 +-
.../apache/ignite/client/fakes/FakeCompute.java | 18 +-
.../ignite/internal/compute/ItComputeBaseTest.java | 4 +-
.../internal/compute/ItComputeTestStandalone.java | 2 +-
.../apache/ignite/internal/compute/PojoJob.java | 8 +-
.../internal/compute/ComputeComponentImpl.java | 6 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 61 ++--
.../internal/compute/IgniteComputeInternal.java | 9 +
.../internal/compute/JobExecutionWrapper.java | 2 +-
...ion.java => ResultMarshallingJobExecution.java} | 24 +-
.../compute/executor/ComputeExecutorImpl.java | 56 +++-
modules/platforms/cpp/ignite/common/error_codes.h | 1 +
modules/platforms/cpp/ignite/odbc/common_types.cpp | 1 +
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 3 +
.../apache/ignite/internal/runner/app/Jobs.java | 309 +++++++++++++++++++++
.../client/ItThinClientComputeMarshallingTest.java | 259 +++++++++++++----
...tThinClientComputeTypeCheckMarshallingTest.java | 233 ++++++++++++++++
.../app/compute/ItEmbeddedMarshallingTest.java | 140 ++++++++++
36 files changed, 1159 insertions(+), 220 deletions(-)
rename
modules/api/src/main/java/org/apache/ignite/{marshaling/ByteArrayMarshaler.java
=> marshalling/ByteArrayMarshaller.java} (65%)
rename
modules/api/src/main/java/org/apache/ignite/{marshaling/JavaSerializationByteArrayMarshallilng.java
=> marshalling/JavaSerializationByteArrayMarshalling.java} (96%)
rename modules/api/src/main/java/org/apache/ignite/{marshaling/Marshaler.java
=> marshalling/Marshaller.java} (75%)
rename modules/api/src/main/java/org/apache/ignite/{marshaling =>
marshalling}/MarshallingException.java (97%)
rename modules/api/src/main/java/org/apache/ignite/{marshaling =>
marshalling}/TupleMarshaller.java (88%)
rename
modules/api/src/main/java/org/apache/ignite/{marshaling/UnsupportedObjectTypeMarshalingException.java
=> marshalling/UnsupportedObjectTypeMarshallingException.java} (81%)
rename
modules/api/src/test/java/org/apache/ignite/{marshaling/ByteArrayMarshalerTest.java
=> marshalling/ByteArrayMarshallerTest.java} (76%)
copy
modules/compute/src/main/java/org/apache/ignite/internal/compute/{DelegatingJobExecution.java
=> ResultMarshallingJobExecution.java} (67%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/Jobs.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientComputeTypeCheckMarshallingTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/compute/ItEmbeddedMarshallingTest.java
