This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git.
from 997f3df first commit
new b757f8d add lease、dim and client module
new 8c20f73 add lease、dim and client module
new 30cb39b modify the README.md
new 0783741 modify the README.md
new ec25277 modify the README.md
new a9450c9 modify the README.md
new ecb842a modify the README.md
new 5555b67 modify the README.md
new 6d89c9a Merge pull request #1 from programer-0/develop
The 10 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 | 25 ++
README.md | 108 ++++-
pom.xml | 410 +++++++++++++++++++
rocketmq-streams-clients/pom.xml | 46 +++
.../rocketmq/streams/client/DataStreamAction.java | 101 +++++
.../rocketmq/streams/client/StreamBuilder.java | 28 ++
.../streams/client/source/DataStreamSource.java | 76 ++++
.../client/strategy/CheckpointStrategy.java | 69 ++++
.../streams/client/strategy/StateStrategy.java | 37 ++
.../rocketmq/streams/client/strategy/Strategy.java | 25 ++
.../streams/client/transform/DataStream.java | 437 +++++++++++++++++++++
.../streams/client/transform/JoinStream.java | 212 ++++++++++
.../streams/client/transform/SplitStream.java | 61 +++
.../streams/client/transform/WindowStream.java | 210 ++++++++++
.../client/transform/window/HoppingWindow.java | 32 ++
.../client/transform/window/SessionWindow.java | 32 ++
.../streams/client/transform/window/Time.java | 45 +++
.../client/transform/window/TumblingWindow.java | 33 ++
.../client/transform/window/WindowInfo.java | 83 ++++
.../rocketmq/streams/client/DBDriverTest.java | 75 ++++
.../rocketmq/streams/client/DataStreamTest.java | 107 +++++
.../apache/rocketmq/streams/client/FilterTest.java | 49 +++
.../apache/rocketmq/streams/client/JoinTest.java | 89 +++++
.../apache/rocketmq/streams/client/LeaseTest.java | 98 +++++
.../rocketmq/streams/client/ORMUtilTest.java | 172 ++++++++
.../apache/rocketmq/streams/client/SplitTest.java | 86 ++++
.../apache/rocketmq/streams/client/UnionTest.java | 82 ++++
.../apache/rocketmq/streams/client/WindowTest.java | 86 ++++
.../client/windows/AbstractWindowFireModeTest.java | 189 +++++++++
.../streams/client/windows/WindowFromFileTest.java | 158 ++++++++
.../streams/client/windows/WindowFromMetaq.java | 47 +++
.../client/windows/WindowHighAvailabilityTest.java | 131 ++++++
.../src/test/resources/log4j.xml | 36 ++
rocketmq-streams-dim/pom.xml | 47 +++
.../apache/rocketmq/streams/dim/DimComponent.java | 63 +++
.../rocketmq/streams/dim/builder/DimBuilder.java | 94 +++++
.../function/expression/InExpressionResource.java | 80 ++++
.../expression/NotInExpressionResource.java | 45 +++
.../dim/function/script/IntelligenceFunction.java | 81 ++++
.../script/IntelligenceNameListFunction.java | 24 ++
.../dim/function/script/NameListFunction.java | 203 ++++++++++
.../rocketmq/streams/dim/index/DimIndex.java | 319 +++++++++++++++
.../rocketmq/streams/dim/index/IndexExecutor.java | 258 ++++++++++++
.../intelligence/AbstractIntelligenceCache.java | 395 +++++++++++++++++++
.../dim/intelligence/AccountIntelligenceCache.java | 77 ++++
.../dim/intelligence/DomainIntelligenceCache.java | 83 ++++
.../dim/intelligence/IPIntelligenceCache.java | 108 +++++
.../dim/intelligence/URLIntelligenceCache.java | 80 ++++
.../rocketmq/streams/dim/model/AbstractDim.java | 312 +++++++++++++++
.../streams/dim/model/BooleanFieldDBDim.java | 55 +++
.../apache/rocketmq/streams/dim/model/DBDim.java | 140 +++++++
.../rocketmq/streams/dim/service/IDimService.java | 65 +++
.../streams/dim/service/impl/DimServiceImpl.java | 92 +++++
.../com/aliyun/service/ConfigureLoaderTest.java | 37 ++
.../com/aliyun/service/ExpressionExecutorTest.java | 80 ++++
.../java/com/aliyun/service/JsonParserTest.java | 40 ++
.../com/aliyun/service/NameListFunctionTest.java | 90 +++++
.../java/com/aliyun/service/TableCompressTest.java | 26 ++
rocketmq-streams-lease/pom.xml | 25 ++
.../rocketmq/streams/lease/LeaseComponent.java | 103 +++++
.../rocketmq/streams/lease/model/LeaseInfo.java | 127 ++++++
.../streams/lease/service/ILeaseGetCallback.java | 30 ++
.../streams/lease/service/ILeaseService.java | 136 +++++++
.../streams/lease/service/ILeaseStorage.java | 73 ++++
.../streams/lease/service/ILeaseStorasge.java | 63 +++
.../lease/service/impl/BasedLesaseImpl.java | 404 +++++++++++++++++++
.../lease/service/impl/LeaseServiceImpl.java | 275 +++++++++++++
.../streams/lease/service/impl/MockLeaseImpl.java | 95 +++++
.../lease/service/storages/DBLeaseStorage.java | 229 +++++++++++
.../rocketmq/streams/lease/LeaseComponentTest.java | 119 ++++++
.../src/test/resources/log4j.xml | 20 +
71 files changed, 8067 insertions(+), 1 deletion(-)
create mode 100644 .gitignore
create mode 100644 pom.xml
create mode 100644 rocketmq-streams-clients/pom.xml
create mode 100644
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/DataStreamAction.java
create mode 100644
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/StreamBuilder.java
create mode 100644
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/source/DataStreamSource.java
create mode 100644
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/strategy/CheckpointStrategy.java
create mode 100644
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/strategy/StateStrategy.java
create mode 100644
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/strategy/Strategy.java
create mode 100644
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/DataStream.java
create mode 100644
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/JoinStream.java
create mode 100644
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/SplitStream.java
create mode 100644
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/WindowStream.java
create mode 100644
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/window/HoppingWindow.java
create mode 100644
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/window/SessionWindow.java
create mode 100644
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/window/Time.java
create mode 100644
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/window/TumblingWindow.java
create mode 100644
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/window/WindowInfo.java
create mode 100644
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/DBDriverTest.java
create mode 100644
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/DataStreamTest.java
create mode 100644
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/FilterTest.java
create mode 100644
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/JoinTest.java
create mode 100644
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/LeaseTest.java
create mode 100644
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/ORMUtilTest.java
create mode 100644
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/SplitTest.java
create mode 100644
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/UnionTest.java
create mode 100644
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/WindowTest.java
create mode 100644
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/AbstractWindowFireModeTest.java
create mode 100644
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/WindowFromFileTest.java
create mode 100644
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/WindowFromMetaq.java
create mode 100644
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/WindowHighAvailabilityTest.java
create mode 100755 rocketmq-streams-clients/src/test/resources/log4j.xml
create mode 100644 rocketmq-streams-dim/pom.xml
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/DimComponent.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/builder/DimBuilder.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/function/expression/InExpressionResource.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/function/expression/NotInExpressionResource.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/function/script/IntelligenceFunction.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/function/script/IntelligenceNameListFunction.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/function/script/NameListFunction.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/index/DimIndex.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/index/IndexExecutor.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/intelligence/AbstractIntelligenceCache.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/intelligence/AccountIntelligenceCache.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/intelligence/DomainIntelligenceCache.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/intelligence/IPIntelligenceCache.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/intelligence/URLIntelligenceCache.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/model/AbstractDim.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/model/BooleanFieldDBDim.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/model/DBDim.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/service/IDimService.java
create mode 100644
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/service/impl/DimServiceImpl.java
create mode 100644
rocketmq-streams-dim/src/test/java/com/aliyun/service/ConfigureLoaderTest.java
create mode 100644
rocketmq-streams-dim/src/test/java/com/aliyun/service/ExpressionExecutorTest.java
create mode 100644
rocketmq-streams-dim/src/test/java/com/aliyun/service/JsonParserTest.java
create mode 100644
rocketmq-streams-dim/src/test/java/com/aliyun/service/NameListFunctionTest.java
create mode 100644
rocketmq-streams-dim/src/test/java/com/aliyun/service/TableCompressTest.java
create mode 100755 rocketmq-streams-lease/pom.xml
create mode 100644
rocketmq-streams-lease/src/main/java/org/apache/rocketmq/streams/lease/LeaseComponent.java
create mode 100644
rocketmq-streams-lease/src/main/java/org/apache/rocketmq/streams/lease/model/LeaseInfo.java
create mode 100644
rocketmq-streams-lease/src/main/java/org/apache/rocketmq/streams/lease/service/ILeaseGetCallback.java
create mode 100644
rocketmq-streams-lease/src/main/java/org/apache/rocketmq/streams/lease/service/ILeaseService.java
create mode 100644
rocketmq-streams-lease/src/main/java/org/apache/rocketmq/streams/lease/service/ILeaseStorage.java
create mode 100644
rocketmq-streams-lease/src/main/java/org/apache/rocketmq/streams/lease/service/ILeaseStorasge.java
create mode 100644
rocketmq-streams-lease/src/main/java/org/apache/rocketmq/streams/lease/service/impl/BasedLesaseImpl.java
create mode 100644
rocketmq-streams-lease/src/main/java/org/apache/rocketmq/streams/lease/service/impl/LeaseServiceImpl.java
create mode 100644
rocketmq-streams-lease/src/main/java/org/apache/rocketmq/streams/lease/service/impl/MockLeaseImpl.java
create mode 100644
rocketmq-streams-lease/src/main/java/org/apache/rocketmq/streams/lease/service/storages/DBLeaseStorage.java
create mode 100644
rocketmq-streams-lease/src/test/java/org/apache/rocketmq/streams/lease/LeaseComponentTest.java
create mode 100755 rocketmq-streams-lease/src/test/resources/log4j.xml
