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 2c2537540e IGNITE-19731 Fixed ItTableScanTest different test failed
(#2209)
add f71681e1af IGNITE-19617 Add basic data streamer to embedded API (#2215)
No new revisions were added by this update.
Summary of changes:
...tClientStreamerPartitionAwarenessProvider.java} | 5 +-
.../internal/client/table/ClientDataStreamer.java | 75 +++++++
.../client/table/ClientKeyValueBinaryView.java | 10 +-
.../internal/client/table/ClientKeyValueView.java | 10 +-
.../client/table/ClientRecordBinaryView.java | 10 +-
.../internal/client/table/ClientRecordView.java | 10 +-
.../client/table/ClientTupleSerializer.java | 1 +
...aluePojoStreamerPartitionAwarenessProvider.java | 2 +-
...lueTupleStreamerPartitionAwarenessProvider.java | 2 +-
.../PojoStreamerPartitionAwarenessProvider.java | 2 +-
.../TupleStreamerPartitionAwarenessProvider.java | 2 +-
.../ignite/client/fakes/FakeInternalTable.java | 6 +
.../internal/streamer}/StreamerBatchSender.java | 4 +-
.../ignite/internal/streamer}/StreamerBuffer.java | 2 +-
.../ignite/internal/streamer/StreamerOptions.java | 53 +++++
.../StreamerPartitionAwarenessProvider.java | 4 +-
.../internal/streamer}/StreamerSubscriber.java | 63 +++---
.../streamer/ItAbstractDataStreamerTest.java | 241 +++++++++++++++++++++
.../streamer/ItClientDataStreamerTest.java} | 27 ++-
.../streamer/ItServerDataStreamerTest.java} | 11 +-
.../internal/schema/marshaller/KvMarshaller.java | 9 +
.../schema/marshaller/RecordMarshaller.java | 10 +
.../marshaller/reflection/KvMarshallerImpl.java | 8 +
.../reflection/RecordMarshallerImpl.java | 9 +
...ctClientStreamerPartitionAwarenessProvider.java | 56 +++++
.../apache/ignite/internal/table/DataStreamer.java | 74 +++++++
.../ignite/internal/table/InternalTable.java | 11 +-
.../internal/table/KeyValueBinaryViewImpl.java | 32 ++-
...aluePojoStreamerPartitionAwarenessProvider.java | 58 +++++
...lueTupleStreamerPartitionAwarenessProvider.java | 25 ++-
.../ignite/internal/table/KeyValueViewImpl.java | 36 ++-
.../PojoStreamerPartitionAwarenessProvider.java | 56 +++++
.../internal/table/RecordBinaryViewImpl.java | 9 +-
.../ignite/internal/table/RecordViewImpl.java | 28 ++-
.../TupleStreamerPartitionAwarenessProvider.java | 47 ++++
.../distributed/storage/InternalTableImpl.java | 47 +++-
36 files changed, 921 insertions(+), 134 deletions(-)
rename
modules/client/src/main/java/org/apache/ignite/internal/client/table/{AbstractStreamerPartitionAwarenessProvider.java
=> AbstractClientStreamerPartitionAwarenessProvider.java} (87%)
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientDataStreamer.java
rename modules/{client/src/main/java/org/apache/ignite/internal/client/table
=>
core/src/main/java/org/apache/ignite/internal/streamer}/StreamerBatchSender.java
(93%)
rename modules/{client/src/main/java/org/apache/ignite/internal/client/table
=> core/src/main/java/org/apache/ignite/internal/streamer}/StreamerBuffer.java
(98%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/streamer/StreamerOptions.java
rename modules/{client/src/main/java/org/apache/ignite/internal/client/table
=>
core/src/main/java/org/apache/ignite/internal/streamer}/StreamerPartitionAwarenessProvider.java
(92%)
rename modules/{client/src/main/java/org/apache/ignite/internal/client/table
=>
core/src/main/java/org/apache/ignite/internal/streamer}/StreamerSubscriber.java
(81%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/streamer/ItAbstractDataStreamerTest.java
copy
modules/{compute/src/main/java/org/apache/ignite/internal/compute/JobExecutionContextImpl.java
=>
runner/src/integrationTest/java/org/apache/ignite/internal/streamer/ItClientDataStreamerTest.java}
(59%)
copy
modules/{api/src/main/java/org/apache/ignite/compute/JobExecutionContext.java
=>
runner/src/integrationTest/java/org/apache/ignite/internal/streamer/ItServerDataStreamerTest.java}
(76%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/AbstractClientStreamerPartitionAwarenessProvider.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/DataStreamer.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/KeyValuePojoStreamerPartitionAwarenessProvider.java
copy modules/{client/src/main/java/org/apache/ignite/internal/client =>
table/src/main/java/org/apache/ignite/internal}/table/KeyValueTupleStreamerPartitionAwarenessProvider.java
(50%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/PojoStreamerPartitionAwarenessProvider.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/TupleStreamerPartitionAwarenessProvider.java
