You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ka...@apache.org on 2023/02/16 02:48:52 UTC
[rocketmq-streams] 01/01: Merge pull request #274 from apache/develop
This is an automated email from the ASF dual-hosted git repository.
karp pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git
commit fb34d1247f76a9fa3f46d77429bcadd5d68d4d30
Merge: 39872381 f546c009
Author: Ni Ze <un...@gmail.com>
AuthorDate: Thu Feb 16 10:48:44 2023 +0800
Merge pull request #274 from apache/develop
release 1.1.1
.gitignore | 4 +-
core/pom.xml | 10 +-
.../rocketmq/streams/core/RocketMQStream.java | 14 +-
.../rocketmq/streams/core/common/Constant.java | 11 +-
.../core/function/accumulator/AvgAccumulator.java | 82 ++++++
.../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 ++++++++++++++++
.../fire/WindowFire.java} | 27 +-
.../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 +-
.../{SlideWindowCount.java => WindowAvg.java} | 43 +--
.../streams/examples/window/WindowCount.java | 31 ++-
.../streams/examples/window/WindowWordCount.java | 14 +-
pom.xml | 2 +-
62 files changed, 1887 insertions(+), 587 deletions(-)