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 c41c8250b1663f0b9ef9e63305017f03375a0716 Merge: b3c4242 6d89c9a Author: Arthur Liang <[email protected]> AuthorDate: Mon Aug 2 13:49:21 2021 +0800 Merge branch 'apache:main' into main .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(-)
