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 96095a157b IGNITE-22770 Fix testBytesSentReceived fail on short
version (#4107)
add 9b271581a7 IGNITE-22285 Implement Embedded Data Streamer with Receiver
(#4103)
No new revisions were added by this update.
Summary of changes:
.../apache/ignite/table/DataStreamerReceiver.java | 2 +-
.../apache/ignite/table/DataStreamerTarget.java | 2 +-
.../apache/ignite/table/ReceiverDescriptor.java | 18 ++--
.../client/proto/ClientBinaryTupleUtils.java | 2 +-
.../client/proto/StreamerReceiverSerializer.java | 120 ++++++++++++++++++---
.../handler/ClientInboundMessageHandler.java | 2 +-
...ClientStreamerWithReceiverBatchSendRequest.java | 67 +-----------
.../internal/client/table/ClientDataStreamer.java | 5 +-
.../client/table/ClientKeyValueBinaryView.java | 2 +-
.../internal/client/table/ClientKeyValueView.java | 2 +-
.../client/table/ClientRecordBinaryView.java | 2 +-
.../internal/client/table/ClientRecordView.java | 2 +-
.../apache/ignite/client/ClientComputeTest.java | 35 ++++--
.../apache/ignite/client/RequestBalancingTest.java | 7 +-
.../ignite/client/TestClientHandlerModule.java | 4 +-
.../java/org/apache/ignite/client/TestServer.java | 6 +-
.../org/apache/ignite/client/fakes/FakeIgnite.java | 10 +-
.../ignite/client/fakes/FakeIgniteTables.java | 14 ++-
.../ignite/client/fakes/FakeInternalTable.java | 33 +++++-
modules/compute/build.gradle | 2 +
.../ignite/internal/compute/IgniteComputeImpl.java | 50 ++++++++-
.../compute/streamer/StreamerReceiverJob.java | 64 +++++++++++
.../replicator/ItReplicaLifecycleTest.java | 3 +
.../streamer/ItAbstractDataStreamerTest.java | 36 ++++++-
.../streamer/ItServerDataStreamerTest.java | 23 ----
.../exec/rel/TableScanNodeExecutionTest.java | 4 +-
.../rebalance/ItRebalanceDistributedTest.java | 3 +
.../ignite/internal/table/ItColocationTest.java | 3 +-
.../apache/ignite/internal/table/DataStreamer.java | 2 +-
.../internal/table/IgniteTablesInternal.java | 2 +
.../ignite/internal/table/InternalTable.java | 7 ++
.../internal/table/KeyValueBinaryViewImpl.java | 30 +++++-
.../ignite/internal/table/KeyValueViewImpl.java | 50 ++++++---
.../internal/table/RecordBinaryViewImpl.java | 30 +++++-
.../ignite/internal/table/RecordViewImpl.java | 48 ++++++---
.../internal/table/StreamerReceiverRunner.java | 63 +++++++++++
.../internal/table/distributed/TableManager.java | 13 ++-
.../distributed/storage/InternalTableImpl.java | 12 ++-
.../distributed/TableManagerRecoveryTest.java | 3 +
.../table/distributed/TableManagerTest.java | 3 +
.../storage/InternalTableEstimatedSizeTest.java | 4 +-
.../distributed/storage/InternalTableImplTest.java | 5 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 4 +-
.../table/impl/DummyInternalTableImpl.java | 4 +-
44 files changed, 612 insertions(+), 191 deletions(-)
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/streamer/StreamerReceiverJob.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/StreamerReceiverRunner.java
