This is an automated email from the ASF dual-hosted git repository. duhengforever pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git
commit 1b71925435f3a90c3d23713099412ffeb2faac79 Merge: 177cc75 513deaf Author: rongtong <[email protected]> AuthorDate: Mon Aug 2 19:18:58 2021 +0800 Merge pull request #3 from xstorm1/dev merge to main branch 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 ++ rocketmq-streams-serviceloader/pom.xml | 24 + .../serviceloader/IServiceLoaderService.java | 31 + .../serviceloader/ServiceLoaderComponent.java | 132 + .../namefinder/IServiceNameGetter.java | 30 + .../impl/AnnotationServiceNameGetter.java | 39 + .../streams/serviceloader/utils/FileUtil.java | 73 + .../component/ServiceLoaderComponent.properties | 1 + .../serviceloader/ServiceLoaderComponentTest.java | 17 + .../src/test/resources/log4j.xml | 20 + rocketmq-streams-window/pom.xml | 36 + .../streams/window/builder/WindowBuilder.java | 95 + .../streams/window/model/FunctionExecutor.java | 51 + .../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 | 20 + .../streams/window/state/impl/JoinRightState.java | 20 + .../streams/window/state/impl/JoinState.java | 94 + .../streams/window/state/impl/WindowValue.java | 548 ++++ .../window/storage/AbstractWindowStorage.java | 120 + .../streams/window/storage/ICommonStorage.java | 50 + .../streams/window/storage/IKeyGenerator.java | 29 + .../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 | 84 + .../streams/configurable/model/Person.java | 97 + .../streams/window/WindowInstanceTest.java | 122 + .../streams/window/WindowMaxValueTest.java | 35 + .../rocketmq/streams/window/WindowValueTest.java | 36 + .../src/test/resources/log4j.xml | 20 + 61 files changed, 12642 insertions(+)
