This is an automated email from the ASF dual-hosted git repository.
ptupitsyn pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from a1fc0560d2 IGNITE-22242 Inject LogStorageFactory dependency in Loza &
JRaftServer (#3757)
add d3ab331241 IGNITE-19544 Java thin: Add Data Streamer with Receiver
(#3812)
No new revisions were added by this update.
Summary of changes:
.../org/apache/ignite/table/DataStreamerItem.java | 13 ++
...reamerTarget.java => DataStreamerReceiver.java} | 34 ++--
.../DataStreamerReceiverContext.java} | 13 +-
.../apache/ignite/table/DataStreamerTarget.java | 30 +++-
.../client/proto/ClientBinaryTupleUtils.java | 188 +++++++++++++++++++-
.../internal/client/proto/ClientMessagePacker.java | 30 ++--
.../client/proto/ClientMessageUnpacker.java | 29 +--
.../ignite/internal/client/proto/ClientOp.java | 7 +-
.../client/proto/StreamerReceiverSerializer.java | 167 ++++++++++++++++++
.../handler/ClientInboundMessageHandler.java | 5 +
.../ClientComputeExecuteColocatedRequest.java | 3 +-
.../ClientComputeExecuteMapReduceRequest.java | 3 +-
.../compute/ClientComputeExecuteRequest.java | 20 +--
...ClientStreamerWithReceiverBatchSendRequest.java | 129 ++++++++++++++
.../apache/ignite/client/ClientOperationType.java | 5 +
.../org/apache/ignite/client/RetryReadPolicy.java | 1 +
.../apache/ignite/internal/client/ClientUtils.java | 3 +
.../internal/client/compute/ClientCompute.java | 12 +-
.../internal/client/table/ClientDataStreamer.java | 90 +++++++++-
.../client/table/ClientKeyValueBinaryView.java | 34 ++++
.../internal/client/table/ClientKeyValueView.java | 34 ++++
.../client/table/ClientRecordBinaryView.java | 34 ++++
.../internal/client/table/ClientRecordView.java | 32 ++++
.../org/apache/ignite/client/DataStreamerTest.java | 195 ++++++++++++++++++++-
.../ignite/client/PartitionAwarenessTest.java | 87 ++++++---
.../java/org/apache/ignite/client/TestServer.java | 7 +-
.../apache/ignite/client/fakes/FakeCompute.java | 18 +-
.../ignite/client/fakes/FakeInternalTable.java | 5 +-
.../internal/compute/ComputeComponentImpl.java | 2 +-
.../ignite/internal/compute/ComputeUtils.java | 46 +++++
.../internal/compute/JobExecutionContextImpl.java | 21 ++-
.../internal/compute/executor/ComputeExecutor.java | 7 +-
.../compute/executor/ComputeExecutorImpl.java | 4 +-
.../internal/compute/loader/JobClassLoader.java | 3 +-
.../ignite/internal/compute/queue/QueueEntry.java | 2 +-
.../compute/JobExecutionContextImplTest.java | 4 +-
.../compute/executor/ComputeExecutorTest.java | 6 +
.../ignite/internal/streamer/StreamerBuffer.java | 8 +-
.../internal/streamer/StreamerSubscriber.java | 45 +++--
.../internal/table/partition/HashPartition.java | 6 +
.../internal/streamer/StreamerSubscriberTest.java | 8 +-
.../streamer/ItAbstractDataStreamerTest.java | 133 ++++++++++++++
.../streamer/ItServerDataStreamerTest.java | 23 +++
.../apache/ignite/internal/table/DataStreamer.java | 28 ++-
.../internal/table/KeyValueBinaryViewImpl.java | 16 ++
.../ignite/internal/table/KeyValueViewImpl.java | 16 ++
.../internal/table/PublicApiThreadingViewBase.java | 25 +++
.../internal/table/RecordBinaryViewImpl.java | 17 ++
.../ignite/internal/table/RecordViewImpl.java | 16 ++
49 files changed, 1517 insertions(+), 147 deletions(-)
copy
modules/api/src/main/java/org/apache/ignite/table/{DataStreamerTarget.java =>
DataStreamerReceiver.java} (50%)
copy
modules/api/src/main/java/org/apache/ignite/{compute/task/TaskExecutionContext.java
=> table/DataStreamerReceiverContext.java} (79%)
create mode 100644
modules/client-common/src/main/java/org/apache/ignite/internal/client/proto/StreamerReceiverSerializer.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/table/ClientStreamerWithReceiverBatchSendRequest.java
