This is an automated email from the ASF dual-hosted git repository.
isapego pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from ad38bf0af57 IGNITE-26078 Update transactions Java example (#6346)
add 8a93cd8318c IGNITE-26082 Update Streaming API examples (#6348)
No new revisions were added by this update.
Summary of changes:
.../{pojo/AccountValue.java => Account.java} | 79 +++--
.../streaming/DetectFailedEntriesExample.java | 96 ++++++
.../DistributedComputeWithReceiverExample.java | 144 ++++++++
.../streaming/KeyValueViewDataStreamerExample.java | 219 ------------
.../KeyValueViewPojoDataStreamerExample.java | 219 ------------
.../streaming/MultiTableDataStreamerExample.java | 97 ++++++
.../streaming/RecordViewDataStreamerExample.java | 217 ------------
.../RecordViewPojoDataStreamerExample.java | 213 ------------
.../streaming/SingleTableDataStreamerExample.java | 132 +++++++
.../ignite/example/streaming/TwoTableReceiver.java | 44 +++
.../ignite/example/streaming/pojo/Account.java | 98 ------
.../ignite/example/streaming/pojo/AccountKey.java | 50 ---
.../ignite/example/streaming/pojo/Trade.java | 118 -------
.../receiver/ReceiverStreamProcessingExample.java | 276 ---------------
...treamProcessingWithResultSubscriberExample.java | 342 -------------------
...iverStreamProcessingWithTableUpdateExample.java | 379 ---------------------
16 files changed, 557 insertions(+), 2166 deletions(-)
rename
examples/src/main/java/org/apache/ignite/example/streaming/{pojo/AccountValue.java
=> Account.java} (52%)
create mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/DetectFailedEntriesExample.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/DistributedComputeWithReceiverExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/KeyValueViewDataStreamerExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/KeyValueViewPojoDataStreamerExample.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/MultiTableDataStreamerExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/RecordViewDataStreamerExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/RecordViewPojoDataStreamerExample.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/SingleTableDataStreamerExample.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/TwoTableReceiver.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/pojo/Account.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/pojo/AccountKey.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/pojo/Trade.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/receiver/ReceiverStreamProcessingExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/receiver/ReceiverStreamProcessingWithResultSubscriberExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/receiver/ReceiverStreamProcessingWithTableUpdateExample.java
