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 39872381 [maven-release-plugin] prepare for next development iteration
add 99fe551f add .gitignore
add e2e722a7 fix(bug) use normal topic as state topic.
add d8d30c3e add isRunning in RocketMQStream
add cbbde831 make state topic consistant with shuffle topic
add a4826419 modify create normal topic
add 89272f9b add log
add 5e1dd642 use the name of thread as rocksdb path.
add 5607482e Merge pull request #252 from ni-ze/develop
add f499b197 Merge pull request #254 from ni-ze/develop
add 1a935323 Merge branch 'local/upstream/develop' into develop
add 73146ed4 repeated stop in workerThread
add 45f24e31 modify the name of workeThread
add 4a6237eb move log
add 102cae55 change operator name of groupedstream
add 2906e9b2 modify the configure of ObjectMapper.
add ca82d3b1 idle window 0.1
add 16e1f3ea idle window 0.2
add d5db2a22 idle window 0.3
add 1dd13c3c modify windowCount example
add 462196f1 polish example
add de18512b store watermark
add f8914810 modify log level
add c86a723e add watermark in session window
add 14c94880 modify the constant
add fb1a307e persist watermark after fired.
add 47d1c6c5 two stream join 0.1
add af0a8462 two stream join 0.2
add 51d13d5e Merge pull request #256 from ni-ze/develop
add d6b934a8 Merge pull request #258 from ni-ze/develop
add 86f18192 Merge pull request #260 from ni-ze/develop
add b9fe94d0 Merge pull request #262 from ni-ze/develop
add 608ccaec Merge pull request #264 from ni-ze/develop
add fabc5712 Merge branch 'local/upstream/develop' into develop
add 3e94af34 add log
add 2bb863b7 add example
add 5c7608da modify schedule execute service
add 854df3a0 modify schedule thread num
add 7c0ceee4 Merge pull request #266 from ni-ze/develop
add 57e31e7e Merge branch 'local/upstream/develop' into develop
add ff510112 modify log level
add 81607e64 remove redundant code
add daf22d73 [ISSUE #251]Support avg function in WindowStream
add 6e17ed81 Merge branch 'develop' into develop_avg
add e6eec5de [ISSUE #251] Update windowAvg examples
add 652c9acf Merge branch 'develop' into develop_avg
add b5355dec Merge pull request #259 from Jargon9/develop_avg
add b6dac328 Merge branch 'local/upstream/develop' into develop
add 97e2568c remove redundancy code
add c81b5515 modify the num of shuffle topic queue
add 9bff38e7 Merge pull request #269 from ni-ze/develop
add a256c965 modify the return type of flatmap
add ecf01cf6 Merge pull request #271 from ni-ze/develop
add 7b85a181 [maven-release-plugin] prepare release
rocketmq-streams-all-1.1.1
add 159f6b77 [maven-release-plugin] prepare for next development iteration
add f546c009 Merge pull request #273 from apache/local/upstream/develop
new fb34d124 Merge pull request #274 from apache/develop
The 1 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:
.gitignore | 4 +-
core/pom.xml | 10 +-
.../rocketmq/streams/core/RocketMQStream.java | 14 +-
.../rocketmq/streams/core/common/Constant.java | 11 +-
.../{MinAccumulator.java => AvgAccumulator.java} | 49 +++-
.../function/supplier/AccumulatorSupplier.java | 4 +-
.../core/function/supplier/AggregateSupplier.java | 4 +-
.../function/supplier/JoinAggregateSupplier.java | 4 +-
.../supplier/JoinWindowAggregateSupplier.java | 136 +++-------
.../core/function/supplier/SinkSupplier.java | 9 +-
.../core/function/supplier/SourceSupplier.java | 14 -
.../supplier/TimestampSelectorSupplier.java | 9 +-
.../supplier/WindowAccumulatorSupplier.java | 163 +++++-------
.../function/supplier/WindowAggregateSupplier.java | 149 +++++------
.../streams/core/metadata/StreamConfig.java | 21 +-
.../streams/core/rstream/GroupedStreamImpl.java | 14 +-
.../rocketmq/streams/core/rstream/Pipeline.java | 4 +
.../rocketmq/streams/core/rstream/RStream.java | 2 +-
.../rocketmq/streams/core/rstream/RStreamImpl.java | 2 +-
.../streams/core/rstream/StreamBuilder.java | 4 +
.../streams/core/rstream/WindowStream.java | 10 +-
.../streams/core/rstream/WindowStreamImpl.java | 32 ++-
.../streams/core/running/AbstractProcessor.java | 27 +-
.../core/running/AbstractWindowProcessor.java | 47 +++-
.../core/running/MessageQueueListenerWrapper.java | 4 -
.../streams/core/running/RocketMQClient.java | 4 +
.../streams/core/running/StreamContext.java | 13 +-
.../streams/core/running/StreamContextImpl.java | 68 ++++-
.../streams/core/running/WorkerThread.java | 105 +++++---
.../serialization/deImpl/KVJsonDeserializer.java | 13 +
.../serialization/serImpl/KVJsonSerializer.java | 12 +
.../rocketmq/streams/core/state/AbstractStore.java | 32 ++-
.../rocketmq/streams/core/state/RocketMQStore.java | 16 +-
.../rocketmq/streams/core/state/RocksDBStore.java | 62 +++--
.../core/topology/virtual/ProcessorNode.java | 2 +
.../streams/core/util/OperatorNameMaker.java | 24 +-
.../rocketmq/streams/core/util/RocketMQUtil.java | 96 ++++++-
.../apache/rocketmq/streams/core/util/Utils.java | 45 +++-
.../apache/rocketmq/streams/core/window/Time.java | 7 +-
.../rocketmq/streams/core/window/WindowKey.java | 31 +++
.../rocketmq/streams/core/window/WindowStore.java | 18 +-
.../core/window/fire/AbstractWindowFire.java | 47 ++++
.../window/fire/AccumulatorSessionWindowFire.java | 100 +++++++
.../core/window/fire/AccumulatorWindowFire.java | 96 +++++++
.../window/fire/AggregateSessionWindowFire.java | 97 +++++++
.../core/window/fire/AggregateWindowFire.java | 91 +++++++
.../streams/core/window/fire/IdleWindowScaner.java | 287 +++++++++++++++++++++
.../streams/core/window/fire/JoinWindowFire.java | 227 ++++++++++++++++
.../GraphNode.java => window/fire/WindowFire.java} | 25 +-
.../streams/core/state/RocksDBStoreTest.java | 2 +-
example/pom.xml | 2 +-
.../rocketmq/streams/examples/WordCount.java | 11 +-
.../streams/examples/joinWindow/JoinWindow.java | 8 +-
.../{JoinWindow.java => JoinWithoutWindow.java} | 20 +-
.../rocketmq/streams/examples/pojo/Demo.java | 7 +-
.../streams/examples/sink/WordCountSink.java | 14 +-
.../examples/window/SessionWindowCount.java | 10 +-
.../streams/examples/window/SlideWindowCount.java | 10 +-
.../{SessionWindowCount.java => WindowAvg.java} | 42 +--
.../streams/examples/window/WindowCount.java | 31 ++-
.../streams/examples/window/WindowWordCount.java | 14 +-
pom.xml | 2 +-
62 files changed, 1841 insertions(+), 597 deletions(-)
copy
core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/{MinAccumulator.java
=> AvgAccumulator.java} (52%)
create mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AbstractWindowFire.java
create mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java
create mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorWindowFire.java
create mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java
create mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateWindowFire.java
create mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java
create mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/JoinWindowFire.java
copy
core/src/main/java/org/apache/rocketmq/streams/core/{topology/virtual/GraphNode.java
=> window/fire/WindowFire.java} (64%)
copy
example/src/main/java/org/apache/rocketmq/streams/examples/joinWindow/{JoinWindow.java
=> JoinWithoutWindow.java} (89%)
copy
example/src/main/java/org/apache/rocketmq/streams/examples/window/{SessionWindowCount.java
=> WindowAvg.java} (67%)
