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 607418a9c9ce2fedd322fee5ead5395d1698abaf Merge: 2564d59 f349dd9 Author: xstorm1 <[email protected]> AuthorDate: Mon Aug 2 15:40:00 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-db-operator/pom.xml | 34 ++ .../rocketmq-streams-db-operator.iml | 16 + .../streams/db/configuable/DBConfigureService.java | 282 ++++++++++++ .../DBSupportParentConfigureService.java | 37 ++ .../rocketmq/streams/db/driver/DriverBuilder.java | 111 +++++ .../rocketmq/streams/db/driver/IDriverBudiler.java | 36 ++ .../rocketmq/streams/db/driver/JDBCDriver.java | 277 ++++++++++++ .../db/driver/batchloader/BatchRowLoader.java | 179 ++++++++ .../db/driver/batchloader/IRowOperator.java | 33 ++ .../rocketmq/streams/db/driver/orm/ORMUtil.java | 490 +++++++++++++++++++++ .../rocketmq/streams/db/operator/SQLOperator.java | 178 ++++++++ .../org/apache/rocketmq/streams/db/Person.java | 110 +++++ .../DBSupportParentConfigureServiceTest.java | 74 ++++ .../streams/db/driver/orm/ORMUtilTest.java | 86 ++++ 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 + rocketmq-streams-transport-minio/pom.xml | 25 ++ .../rocketmq-streams-transport-minio.iml | 17 + .../transport/minio/MinioFileTransport.java | 141 ++++++ .../yundun/dipper/configurable/DataTpyeTest.java | 70 +++ .../streams/configuable/model/DataTpyeTest.java | 68 +++ .../rocketmq/streams/configuable/model/Person.java | 97 ++++ .../streams/configurable/model/Person.java | 97 ++++ .../component/ConfigurableComponent.properties | 7 + .../src/test/resources/log4j.xml | 20 + .../src/test/resources/pro-function.txt | 11 + .../src/test/resources/python_script.py | 22 + 96 files changed, 10585 insertions(+), 1 deletion(-)
