[rocketmq-streams] branch main updated (2664360e -> f993d451)

[ka...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

karp pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git


    from 2664360e Merge pull request #242 from ni-ze/newWorld-4
     new ffab57c6 modify start method.
     new ae0fa0f0 modify start method.
     new 2fd45bd2 modify start method.
     new 7e6825e9 add flatmap, add tostring, modify the key of sink topic
     new f993d451 Merge pull request #243 from ni-ze/newWorld-4

The 698 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 core/pom.xml                                       |  16 +---
 .../rocketmq/streams/core/RocketMQStream.java      |  21 +++--
 ...Supplier.java => MultiValueChangeSupplier.java} |  25 +++---
 .../core/function/supplier/SinkSupplier.java       |   8 +-
 .../function/supplier/ValueChangeSupplier.java     |  20 +----
 .../rocketmq/streams/core/rstream/RStream.java     |   2 +-
 .../rocketmq/streams/core/rstream/RStreamImpl.java |  10 ++-
 .../streams/core/running/WorkerThread.java         |   1 +
 .../serialization/deImpl/KVAvroDeserializer.java   | 100 ---------------------
 .../serialization/serImpl/KVAvroSerializer.java    | 100 ---------------------
 .../topology/virtual/ShuffleProcessorNode.java     |   5 ++
 .../core/topology/virtual/SinkGraphNode.java       |   5 ++
 .../core/topology/virtual/SourceGraphNode.java     |   5 +-
 .../streams/core/util/OperatorNameMaker.java       |   1 +
 .../rocketmq/streams/core/util/RocketMQUtil.java   |  12 +--
 .../apache/rocketmq/streams/core/util/Utils.java   |  26 ++++--
 .../rocketmq/streams/examples/WordCount.java       |  20 ++++-
 .../rocketmq/streams/examples/pojo/Demo.java       |   1 +
 .../window/{windowCount.java => WindowCount.java}  |   2 +-
 .../{windowWordCount.java => WindowWordCount.java} |   2 +-
 20 files changed, 105 insertions(+), 277 deletions(-)
 copy core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/{TimestampSelectorSupplier.java => MultiValueChangeSupplier.java} (58%)
 delete mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/serialization/deImpl/KVAvroDeserializer.java
 delete mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/serialization/serImpl/KVAvroSerializer.java
 rename example/src/main/java/org/apache/rocketmq/streams/examples/window/{windowCount.java => WindowCount.java} (99%)
 rename example/src/main/java/org/apache/rocketmq/streams/examples/window/{windowWordCount.java => WindowWordCount.java} (98%)