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 803b738636 IGNITE-19451 Prohibit some types from being Marshallable
(#2163)
add 673602c6f8 IGNITE-19540 Add Basic Data Streamer (#2128)
No new revisions were added by this update.
Summary of changes:
.../apache/ignite/table/DataStreamerOptions.java | 176 ++++++++++++
.../apache/ignite/table/DataStreamerTarget.java} | 20 +-
.../java/org/apache/ignite/table/KeyValueView.java | 3 +-
.../java/org/apache/ignite/table/RecordView.java | 2 +-
.../ignite/internal/client/ReliableChannel.java | 25 +-
.../ignite/internal/client/TcpClientChannel.java | 12 +-
.../internal/client/compute/ClientCompute.java | 2 +-
...AbstractStreamerPartitionAwarenessProvider.java | 60 +++++
.../client/table/ClientKeyValueBinaryView.java | 33 ++-
.../internal/client/table/ClientKeyValueView.java | 37 +++
.../client/table/ClientRecordBinaryView.java | 31 +++
.../internal/client/table/ClientRecordView.java | 32 ++-
.../ignite/internal/client/table/ClientTable.java | 61 ++++-
.../client/table/ClientTupleSerializer.java | 15 +-
...luePojoStreamerPartitionAwarenessProvider.java} | 29 +-
...ueTupleStreamerPartitionAwarenessProvider.java} | 25 +-
.../client/table/PartitionAwarenessProvider.java | 17 +-
.../PojoStreamerPartitionAwarenessProvider.java} | 28 +-
.../client/table/StreamerBatchSender.java} | 19 +-
.../internal/client/table/StreamerBuffer.java | 98 +++++++
.../table/StreamerPartitionAwarenessProvider.java} | 24 +-
.../internal/client/table/StreamerSubscriber.java | 253 ++++++++++++++++++
.../TupleStreamerPartitionAwarenessProvider.java} | 24 +-
...oggerFactory.java => ConsoleLoggerFactory.java} | 55 ++--
.../org/apache/ignite/client/DataStreamerTest.java | 297 +++++++++++++++++++++
.../ignite/client/PartitionAwarenessTest.java | 160 +++++++++--
.../internal/table/KeyValueBinaryViewImpl.java | 10 +
.../ignite/internal/table/KeyValueViewImpl.java | 10 +
.../internal/table/RecordBinaryViewImpl.java | 9 +
.../ignite/internal/table/RecordViewImpl.java | 9 +
30 files changed, 1395 insertions(+), 181 deletions(-)
create mode 100644
modules/api/src/main/java/org/apache/ignite/table/DataStreamerOptions.java
copy
modules/{binary-tuple/src/main/java/org/apache/ignite/internal/binarytuple/BinaryTupleContainer.java
=> api/src/main/java/org/apache/ignite/table/DataStreamerTarget.java} (61%)
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/table/AbstractStreamerPartitionAwarenessProvider.java
copy
modules/{core/src/main/java/org/apache/ignite/internal/util/IteratorCursor.java
=>
client/src/main/java/org/apache/ignite/internal/client/table/KeyValuePojoStreamerPartitionAwarenessProvider.java}
(57%)
copy modules/{api/src/main/java/org/apache/ignite/sql/SqlRow.java =>
client/src/main/java/org/apache/ignite/internal/client/table/KeyValueTupleStreamerPartitionAwarenessProvider.java}
(61%)
copy
modules/{catalog/src/main/java/org/apache/ignite/internal/catalog/commands/DropTableParams.java
=>
client/src/main/java/org/apache/ignite/internal/client/table/PojoStreamerPartitionAwarenessProvider.java}
(61%)
copy
modules/{configuration-api/src/main/java/org/apache/ignite/configuration/notifications/ConfigurationListener.java
=>
client/src/main/java/org/apache/ignite/internal/client/table/StreamerBatchSender.java}
(66%)
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/table/StreamerBuffer.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/AsyncCloseable.java
=>
client/src/main/java/org/apache/ignite/internal/client/table/StreamerPartitionAwarenessProvider.java}
(59%)
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/table/StreamerSubscriber.java
copy modules/{api/src/main/java/org/apache/ignite/sql/SqlRow.java =>
client/src/main/java/org/apache/ignite/internal/client/table/TupleStreamerPartitionAwarenessProvider.java}
(65%)
copy
modules/client/src/test/java/org/apache/ignite/client/{TestLoggerFactory.java
=> ConsoleLoggerFactory.java} (63%)
create mode 100644
modules/client/src/test/java/org/apache/ignite/client/DataStreamerTest.java
