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 cdacbf97 Merge pull request #229 from ni-ze/newWorld-4
new 61c6387e add api
new a4ad47fa add acc
new 47d1aae1 remove aggregate from rStream
new ee9c3ee8 support window query
new 65911249 join without window
new 63cbefa6 adjust jobId
new afcf328d adjust start method
new 8b004d2a add pom fastjson
new b2a68b73 add groupstream operator
new ebaf708f modify demo
new 41d95a2f remove properties
new 343a28ae add sink
new 51bb0c83 modify the package path and artifactId in pom
new 5ed57f1c Merge pull request #231 from ni-ze/newWorld-4
The 674 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 | 1 +
README-chinese.md | 168 ----------------
README.md | 218 ++++++++++-----------
core/pom.xml | 15 +-
.../rocketmq/streams/core/RocketMQStream.java | 15 +-
.../streams/core/function/AggregateAction.java | 1 -
.../{KeySelectAction.java => SelectAction.java} | 4 +-
.../accumulator/Accumulator.java} | 21 +-
.../function/accumulator/CountAccumulator.java | 44 ++---
.../core/function/accumulator/MinAccumulator.java | 61 ++++++
...egateSupplier.java => AccumulatorSupplier.java} | 42 ++--
.../function/supplier/JoinAggregateSupplier.java | 164 ++++++++++++++++
.../supplier/JoinWindowAggregateSupplier.java | 15 +-
.../core/function/supplier/KeySelectSupplier.java | 19 +-
.../core/function/supplier/SourceSupplier.java | 6 +-
.../core/function/supplier/SumAggregate.java | 50 +++++
...upplier.java => WindowAccumulatorSupplier.java} | 123 ++++++------
.../function/supplier/WindowAggregateSupplier.java | 13 +-
.../rocketmq/streams/core/metadata/Data.java | 4 +-
.../streams/core/metadata/StreamConfig.java | 9 +-
.../streams/core/rstream/GroupedStream.java | 33 +++-
.../streams/core/rstream/GroupedStreamImpl.java | 171 +++++++++++++++-
.../streams/core/rstream/JoinedStream.java | 98 ++++++---
.../rocketmq/streams/core/rstream/Pipeline.java | 11 +-
.../rocketmq/streams/core/rstream/RStream.java | 9 +-
.../rocketmq/streams/core/rstream/RStreamImpl.java | 35 ++--
.../streams/core/rstream/StreamBuilder.java | 11 +-
.../streams/core/rstream/WindowStream.java | 12 +-
.../streams/core/rstream/WindowStreamImpl.java | 73 +++++--
.../streams/core/running/AbstractProcessor.java | 4 +
.../core/running/AbstractWindowProcessor.java | 4 +-
.../streams/core/running/StreamContext.java | 1 -
.../streams/core/running/StreamContextImpl.java | 10 +-
.../streams/core/running/WorkerThread.java | 10 +-
.../streams/core/serialization/JsonSerDe.java | 44 -----
.../streams/core/serialization/SerDeWrapper.java | 25 ---
.../rocketmq/streams/core/state/RocketMQStore.java | 22 ++-
.../rocketmq/streams/core/state/RocksDBKey.java | 74 -------
.../rocketmq/streams/core/state/RocksDBStore.java | 185 ++++++-----------
.../rocketmq/streams/core/state/StateStore.java | 5 +-
.../streams/core/topology/TopologyBuilder.java | 9 +-
.../topology/virtual/ShuffleProcessorNode.java | 6 +-
.../streams/core/util/OperatorNameMaker.java | 26 ++-
.../apache/rocketmq/streams/core/util/Utils.java | 29 +--
.../{runtime/operators => window}/JoinType.java | 2 +-
.../{runtime/operators => window}/StreamType.java | 2 +-
.../core/{runtime/operators => window}/Time.java | 2 +-
.../{runtime/operators => window}/TimeType.java | 2 +-
.../core/{runtime/operators => window}/Window.java | 2 +-
.../operators => window}/WindowBuilder.java | 2 +-
.../{runtime/operators => window}/WindowInfo.java | 2 +-
.../{runtime/operators => window}/WindowKey.java | 3 +-
.../{runtime/operators => window}/WindowState.java | 3 +-
.../{runtime/operators => window}/WindowStore.java | 4 +-
core/src/main/resources/logback.xml | 31 +--
.../streams/core/function/AggregateSupplier.java | 2 +-
.../streams/core/runtime/WindowStateTests.java | 2 +-
.../streams/core/state/RocksDBStoreTest.java | 2 +-
example/pom.xml | 18 +-
.../rocketmq/streams/examples/WordCount.java | 21 +-
.../streams/examples/joinWindow/JoinWindow.java | 4 +-
.../rocketmq/streams/examples/pojo/Demo.java | 4 +-
.../rocketmq/streams/examples/pojo/User.java | 9 +
.../examples/window/SessionWindowCount.java | 6 +-
.../streams/examples/window/SlideWindowCount.java | 6 +-
.../streams/examples/window/windowCount.java | 24 ++-
.../streams/examples/window/windowWordCount.java | 8 +-
pom.xml | 8 +-
quick_start.md | 20 --
69 files changed, 1104 insertions(+), 985 deletions(-)
delete mode 100644 README-chinese.md
rename
core/src/main/java/org/apache/rocketmq/streams/core/function/{KeySelectAction.java
=> SelectAction.java} (92%)
copy
core/src/main/java/org/apache/rocketmq/streams/core/{rstream/WindowStream.java
=> function/accumulator/Accumulator.java} (63%)
copy example/src/main/java/org/apache/rocketmq/streams/examples/pojo/Num.java
=>
core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/CountAccumulator.java
(50%)
create mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/MinAccumulator.java
copy
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/{AggregateSupplier.java
=> AccumulatorSupplier.java} (69%)
create mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinAggregateSupplier.java
create mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SumAggregate.java
copy
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/{WindowAggregateSupplier.java
=> WindowAccumulatorSupplier.java} (78%)
delete mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/serialization/JsonSerDe.java
delete mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/serialization/SerDeWrapper.java
delete mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/state/RocksDBKey.java
rename core/src/main/java/org/apache/rocketmq/streams/core/{runtime/operators
=> window}/JoinType.java (93%)
rename core/src/main/java/org/apache/rocketmq/streams/core/{runtime/operators
=> window}/StreamType.java (93%)
rename core/src/main/java/org/apache/rocketmq/streams/core/{runtime/operators
=> window}/Time.java (97%)
rename core/src/main/java/org/apache/rocketmq/streams/core/{runtime/operators
=> window}/TimeType.java (93%)
rename core/src/main/java/org/apache/rocketmq/streams/core/{runtime/operators
=> window}/Window.java (96%)
rename core/src/main/java/org/apache/rocketmq/streams/core/{runtime/operators
=> window}/WindowBuilder.java (96%)
rename core/src/main/java/org/apache/rocketmq/streams/core/{runtime/operators
=> window}/WindowInfo.java (97%)
rename core/src/main/java/org/apache/rocketmq/streams/core/{runtime/operators
=> window}/WindowKey.java (96%)
rename core/src/main/java/org/apache/rocketmq/streams/core/{runtime/operators
=> window}/WindowState.java (98%)
rename core/src/main/java/org/apache/rocketmq/streams/core/{runtime/operators
=> window}/WindowStore.java (96%)
delete mode 100644 quick_start.md
