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 143ba93fb5 IGNITE-22443 Fix sporadic configuration tests failures
(#3895)
add d0004563a1 IGNITE-22302 Add resultSubscriber support to Data Streamer
(#3900)
No new revisions were added by this update.
Summary of changes:
.../apache/ignite/table/DataStreamerTarget.java | 2 +
.../client/proto/ClientBinaryTupleUtils.java | 6 +-
.../client/proto/StreamerReceiverSerializer.java | 4 +-
...ClientStreamerWithReceiverBatchSendRequest.java | 10 +-
.../internal/client/table/ClientDataStreamer.java | 31 +-
.../client/table/ClientKeyValueBinaryView.java | 2 +-
.../internal/client/table/ClientKeyValueView.java | 2 +-
.../client/table/ClientRecordBinaryView.java | 2 +-
.../internal/client/table/ClientRecordView.java | 2 +-
.../org/apache/ignite/client/DataStreamerTest.java | 341 +++++++++++++++++++--
.../internal/streamer/StreamerBatchSender.java | 5 +-
.../internal/streamer/StreamerSubscriber.java | 99 +++++-
.../internal/streamer/StreamerSubscriberTest.java | 4 +-
.../streamer/ItAbstractDataStreamerTest.java | 47 ++-
.../streamer/ItServerDataStreamerTest.java | 10 +-
.../apache/ignite/internal/table/DataStreamer.java | 8 +-
.../internal/table/KeyValueBinaryViewImpl.java | 6 +-
.../ignite/internal/table/KeyValueViewImpl.java | 5 +-
.../internal/table/RecordBinaryViewImpl.java | 6 +-
.../ignite/internal/table/RecordViewImpl.java | 5 +-
20 files changed, 510 insertions(+), 87 deletions(-)
