This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git.
from 177cc75 Merge pull request #4 from speak2me/main
new 2564d59 add rocketmq-streams, rocketmq-channel-rocketmq,
rocketmq-serviceloader module
new f9e1680 modify README.md
new 2fb7d91 modify README.md
new b013eb2 modify README.md
new 607418a Merge branch 'apache:main' into main
new d8216f0 modify README.md
new aa81fe8 modify README.md
new 513deaf delete target directory
new 1b71925 Merge pull request #3 from xstorm1/dev
The 27 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:
rocketmq-streams-channel-rocketmq/pom.xml | 87 +
.../rocketmq/streams/RocketMQChannelBuilder.java | 90 +
.../apache/rocketmq/streams/RocketMQOffset.java | 89 +
.../streams/queue/RocketMQMessageQueue.java | 107 +
.../apache/rocketmq/streams/sink/RocketMQSink.java | 318 +++
.../rocketmq/streams/source/RocketMQSource.java | 292 ++
.../rocketmq/streams/AbstractChannelTest.java | 58 +
.../rocketmq/streams/RocketMQChannelTest.java | 176 ++
.../pom.xml | 9 +-
.../serviceloader/IServiceLoaderService.java | 31 +
.../serviceloader/ServiceLoaderComponent.java | 132 +
.../namefinder/IServiceNameGetter.java | 17 +-
.../impl/AnnotationServiceNameGetter.java | 28 +-
.../streams/serviceloader/utils/FileUtil.java | 73 +
.../component/ServiceLoaderComponent.properties | 1 +
.../serviceloader/ServiceLoaderComponentTest.java | 17 +
.../src/test/resources/log4j.xml | 0
.../pom.xml | 19 +-
.../streams/window/builder/WindowBuilder.java | 95 +
.../streams/window/model/FunctionExecutor.java | 37 +-
.../rocketmq/streams/window/model/WindowCache.java | 149 +
.../streams/window/model/WindowInstance.java | 506 ++++
.../window/offset/IWindowMaxValueManager.java | 87 +
.../streams/window/offset/WindowMaxValue.java | 89 +
.../window/offset/WindowMaxValueManager.java | 247 ++
.../window/operator/AbstractShuffleWindow.java | 83 +
.../streams/window/operator/AbstractWindow.java | 781 ++++++
.../streams/window/operator/impl/OverWindow.java | 154 ++
.../window/operator/impl/SessionWindow.java | 248 ++
.../window/operator/impl/WindowOperator.java | 451 +++
.../streams/window/operator/join/DBOperator.java | 427 +++
.../streams/window/operator/join/JoinWindow.java | 553 ++++
.../streams/window/operator/join/Operator.java | 76 +
.../window/shuffle/AbstractSystemChannel.java | 321 +++
.../streams/window/shuffle/ShuffleChannel.java | 542 ++++
.../streams/window/source/WindowRireSource.java | 336 +++
.../streams/window/state/WindowBaseValue.java | 188 ++
.../streams/window/state/impl/JoinLeftState.java | 9 +-
.../streams/window/state/impl/JoinRightState.java | 9 +-
.../streams/window/state/impl/JoinState.java | 94 +
.../streams/window/state/impl/WindowValue.java | 548 ++++
.../window/storage/AbstractWindowStorage.java | 120 +
.../streams/window/storage/ICommonStorage.java | 29 +-
.../streams/window/storage/IKeyGenerator.java | 16 +-
.../window/storage/IShufflePartitionManager.java | 52 +
.../rocketmq/streams/window/storage/IStorage.java | 79 +
.../streams/window/storage/IWindowStorage.java | 68 +
.../window/storage/ShufflePartitionManager.java | 86 +
.../streams/window/storage/StorageManager.java | 307 +++
.../streams/window/storage/WindowStorage.java | 183 ++
.../streams/window/storage/db/DBStorage.java | 186 ++
.../streams/window/storage/file/FileStorage.java | 196 ++
.../window/storage/rocksdb/RocksdbStorage.java | 293 ++
.../src/main/resources/dipper.cs | 2892 ++++++++++++++++++++
.../src/main/resources/dipper.properties | 21 +
.../streams/configruation}/model/Person.java | 23 +-
.../streams/configurable/model/Person.java | 0
.../streams/window/WindowInstanceTest.java | 122 +
.../streams/window/WindowMaxValueTest.java | 15 +-
.../rocketmq/streams/window/WindowValueTest.java | 16 +-
.../src/test/resources/log4j.xml | 0
61 files changed, 12183 insertions(+), 95 deletions(-)
create mode 100644 rocketmq-streams-channel-rocketmq/pom.xml
create mode 100644
rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/RocketMQChannelBuilder.java
create mode 100644
rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/RocketMQOffset.java
create mode 100644
rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/queue/RocketMQMessageQueue.java
create mode 100644
rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/sink/RocketMQSink.java
create mode 100644
rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/source/RocketMQSource.java
create mode 100644
rocketmq-streams-channel-rocketmq/src/test/java/org/apache/rocketmq/streams/AbstractChannelTest.java
create mode 100644
rocketmq-streams-channel-rocketmq/src/test/java/org/apache/rocketmq/streams/RocketMQChannelTest.java
copy {rocketmq-streams-configurable => rocketmq-streams-serviceloader}/pom.xml
(75%)
create mode 100644
rocketmq-streams-serviceloader/src/main/java/org/apache/rocketmq/streams/serviceloader/IServiceLoaderService.java
create mode 100644
rocketmq-streams-serviceloader/src/main/java/org/apache/rocketmq/streams/serviceloader/ServiceLoaderComponent.java
copy
rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/driver/batchloader/IRowOperator.java
=>
rocketmq-streams-serviceloader/src/main/java/org/apache/rocketmq/streams/serviceloader/namefinder/IServiceNameGetter.java
(78%)
copy
rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/configuable/DBSupportParentConfigureService.java
=>
rocketmq-streams-serviceloader/src/main/java/org/apache/rocketmq/streams/serviceloader/namefinder/impl/AnnotationServiceNameGetter.java
(55%)
create mode 100644
rocketmq-streams-serviceloader/src/main/java/org/apache/rocketmq/streams/serviceloader/utils/FileUtil.java
create mode 100644
rocketmq-streams-serviceloader/src/main/resources/component/ServiceLoaderComponent.properties
create mode 100644
rocketmq-streams-serviceloader/src/test/java/org/apache/rocketmq/streams/serviceloader/ServiceLoaderComponentTest.java
copy {rocketmq-streams-transport-minio =>
rocketmq-streams-serviceloader}/src/test/resources/log4j.xml (100%)
copy {rocketmq-streams-lease => rocketmq-streams-window}/pom.xml (64%)
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/builder/WindowBuilder.java
copy
rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/SplitBySerialNumber.java
=>
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/model/FunctionExecutor.java
(53%)
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/model/WindowCache.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/model/WindowInstance.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/offset/IWindowMaxValueManager.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/offset/WindowMaxValue.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/offset/WindowMaxValueManager.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/AbstractShuffleWindow.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/AbstractWindow.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/impl/OverWindow.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/impl/SessionWindow.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/impl/WindowOperator.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/join/DBOperator.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/join/JoinWindow.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/join/Operator.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/shuffle/AbstractSystemChannel.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/shuffle/ShuffleChannel.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/source/WindowRireSource.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/state/WindowBaseValue.java
copy
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/strategy/Strategy.java
=>
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/state/impl/JoinLeftState.java
(84%)
copy
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/strategy/Strategy.java
=>
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/state/impl/JoinRightState.java
(84%)
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/state/impl/JoinState.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/state/impl/WindowValue.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/AbstractWindowStorage.java
copy
rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/driver/batchloader/IRowOperator.java
=>
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/ICommonStorage.java
(55%)
copy
rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/driver/batchloader/IRowOperator.java
=>
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/IKeyGenerator.java
(78%)
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/IShufflePartitionManager.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/IStorage.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/IWindowStorage.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/ShufflePartitionManager.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/StorageManager.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/WindowStorage.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/db/DBStorage.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/file/FileStorage.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/rocksdb/RocksdbStorage.java
create mode 100644 rocketmq-streams-window/src/main/resources/dipper.cs
create mode 100644 rocketmq-streams-window/src/main/resources/dipper.properties
copy
{rocketmq-streams-transport-minio/src/test/java/org/apache/rocketmq/streams/configuable
=>
rocketmq-streams-window/src/test/java/org/apache/rocketmq/streams/configruation}/model/Person.java
(70%)
copy {rocketmq-streams-transport-minio =>
rocketmq-streams-window}/src/test/java/org/apache/rocketmq/streams/configurable/model/Person.java
(100%)
create mode 100644
rocketmq-streams-window/src/test/java/org/apache/rocketmq/streams/window/WindowInstanceTest.java
copy
rocketmq-streams-dim/src/test/java/com/aliyun/service/TableCompressTest.java =>
rocketmq-streams-window/src/test/java/org/apache/rocketmq/streams/window/WindowMaxValueTest.java
(62%)
copy
rocketmq-streams-dim/src/test/java/com/aliyun/service/TableCompressTest.java =>
rocketmq-streams-window/src/test/java/org/apache/rocketmq/streams/window/WindowValueTest.java
(61%)
copy {rocketmq-streams-transport-minio =>
rocketmq-streams-window}/src/test/resources/log4j.xml (100%)
