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 5ef7b1d Merge pull request #5 from cw68ster/main
new b3c4242 add filter channel-http schedule modules
new c41c825 Merge branch 'apache:main' into main
new 177cc75 Merge pull request #4 from speak2me/main
The 18 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-http/pom.xml | 30 ++
.../rocketmq-streams-channel-http.iml | 62 +++
.../rocketmq/streams/http/source/HttpSource.java | 157 ++++++
.../streams/http/source/server/HttpServer.java | 273 ++++++++++
.../http/source/server/HttpServerManager.java | 60 +++
.../streams/http/source/util/HttpUtil.java | 251 +++++++++
.../streams/http/source/http/HttpChannelTest.java | 38 +-
.../pom.xml | 20 +-
.../rocketmq-streams-filter.iml | 72 +++
.../rocketmq/streams/filter/FilterComponent.java | 115 ++++
.../streams/filter/builder/ExpressionBuilder.java | 409 ++++++++++++++
.../streams/filter/builder/RuleBuilder.java | 592 +++++++++++++++++++++
.../streams/filter/builder/RuleElementBuilder.java | 137 +++++
.../streams/filter/contants/RuleElementType.java | 32 +-
.../streams/filter/contants/RuleStatus.java | 98 ++++
.../streams/filter/context/ContextConfigure.java | 272 ++++++++++
.../streams/filter/context/RuleContext.java | 399 ++++++++++++++
.../streams/filter/context/RuleMessage.java | 33 +-
.../streams/filter/engine/IRuleEngine.java | 51 ++
.../rocketmq/streams/filter/engine/SplitFlow.java | 159 ++++++
.../filter/engine/impl/DefaultRuleEngine.java | 280 ++++++++++
.../filter/exception/RegexTimeoutException.java | 48 ++
.../filter/function/etl/RenameFunction.java | 17 +-
.../expression/AbstractExpressionFunction.java | 67 +++
.../function/expression/CompareFunction.java | 74 +++
.../ContainsCaseInsensitiveFunction.java | 74 +++
.../function/expression/ContainsFunction.java | 47 +-
.../streams/filter/function/expression/Equals.java | 166 ++++++
.../function/expression/ExpressionFunction.java | 20 +-
.../filter/function/expression/GreaterEquals.java | 163 ++++++
.../filter/function/expression/GreaterThan.java | 132 +++++
.../filter/function/expression/InFunction.java | 85 +++
.../filter/function/expression/InMetaData.java | 52 +-
.../function/expression/IpContainsFunction.java | 180 +++++++
.../filter/function/expression/IsNotNull.java | 35 +-
.../streams/filter/function/expression/IsNull.java | 34 +-
.../filter/function/expression/LessEquals.java | 118 ++++
.../filter/function/expression/LessThan.java | 119 +++++
.../filter/function/expression/LikeFunction.java | 167 ++++++
.../NotContainsCaseInsensitiveFunction.java | 76 +++
.../function/expression/NotContainsFunction.java | 48 +-
.../filter/function/expression/NotEquals.java | 169 ++++++
.../filter/function/expression/NotInFunction.java | 20 +-
.../function/expression/NotLikeFunction.java | 19 +-
.../NotRegexCaseInsensitiveFunction.java | 21 +-
.../function/expression/NotRegexFunction.java | 21 +-
.../expression/RegexCaseInsensitiveFunction.java | 24 +-
.../filter/function/expression/RegexFunction.java | 123 +++++
.../filter/function/expression/ScriptFunction.java | 145 +++++
.../filter/function/script/CaseFunction.java | 86 +++
.../rocketmq/streams/filter/monitor/Monitor.java | 160 ++++++
.../filter/monitor/contants/MonitorType.java | 35 +-
.../streams/filter/monitor/rule/ActionMonitor.java | 13 +-
.../filter/monitor/rule/ExpressionMonitor.java | 13 +-
.../filter/monitor/rule/MessageMonitor.java | 119 +++++
.../streams/filter/monitor/rule/NullMonitor.java | 35 +-
.../streams/filter/monitor/rule/RuleMonitor.java | 62 +++
.../streams/filter/monitor/rule/VarMonitor.java | 13 +-
.../streams/filter/operator/FilterOperator.java | 13 +-
.../rocketmq/streams/filter/operator/Rule.java | 538 +++++++++++++++++++
.../streams/filter/operator/action/Action.java | 12 +-
.../operator/action/IConfigurableAction.java | 27 +-
.../filter/operator/action/impl/ChannelAction.java | 69 +++
.../operator/action/impl/MetaDataAction.java | 185 +++++++
.../filter/operator/expression/Expression.java | 405 ++++++++++++++
.../operator/expression/ExpressionPerformance.java | 99 ++++
.../expression/ExpressionRelationParser.java | 106 ++++
.../expression/ExpressionRelationPaser.java | 107 ++++
.../operator/expression/GroupExpression.java | 146 +++++
.../expression/GroupExpressionManager.java | 86 +++
.../operator/expression/OptimizationRule.java | 19 +-
.../operator/expression/RelationExpression.java | 347 ++++++++++++
.../operator/expression/SimpleExpression.java | 113 ++++
.../streams/filter/operator/var/ConstantVar.java | 118 ++++
.../streams/filter/operator/var/ContextVar.java | 85 +++
.../streams/filter/operator/var/InnerVar.java | 86 +++
.../rocketmq/streams/filter/operator/var/Var.java | 79 +++
.../optimization/EqualsExpressionOptimization.java | 39 ++
.../optimization/ExpressionOptimization.java | 144 +++++
.../optimization/IExpressionOptimization.java | 24 +-
.../optimization/LikeExpressionOptimization.java | 39 ++
.../optimization/OptimizationExpression.java | 71 +++
.../PiplineLogFingerprintAnalysis.java | 433 +++++++++++++++
.../optimization/RegexExpressionOptimization.java | 39 ++
.../streams/filter/service/IRuleEngineService.java | 30 +-
.../filter/service/impl/RuleEngineServiceImpl.java | 104 ++++
.../rocketmq/streams/filter/utils/IPUtil.java | 209 ++++++++
.../rocketmq/streams/filter/utils/RegexUtil.java | 211 ++++++++
.../streams/filter/FilterComponentTest.java | 29 +-
.../streams/filter/operator/ExpressionTest.java | 40 +-
.../rocketmq/streams/filter/operator/RuleTest.java | 40 ++
.../test/resources/credible/ChannelComponent.xml | 70 +++
.../resources/credible/credible-channel.properties | 12 +
.../test/resources/credible/credible.properties | 8 +
.../src/test/resources/log4j.xml | 0
.../pom.xml | 20 +-
.../rocketmq-streams-schedule.iml | 65 +++
.../streams/schedule/ScheduleComponent.java | 56 +-
.../schedule/job/ConfigurableExecutorJob.java | 55 ++
.../streams/schedule/service/IScheduleService.java | 90 ++++
.../schedule/service/impl/ScheduleServiceImpl.java | 264 +++++++++
.../stream/schedule/ScheduleComponentTest.java | 62 +++
.../src/test/resources/log4j.xml | 0
103 files changed, 10767 insertions(+), 367 deletions(-)
create mode 100644 rocketmq-streams-channel-http/pom.xml
create mode 100644
rocketmq-streams-channel-http/rocketmq-streams-channel-http.iml
create mode 100644
rocketmq-streams-channel-http/src/main/java/org/apache/rocketmq/streams/http/source/HttpSource.java
create mode 100644
rocketmq-streams-channel-http/src/main/java/org/apache/rocketmq/streams/http/source/server/HttpServer.java
create mode 100644
rocketmq-streams-channel-http/src/main/java/org/apache/rocketmq/streams/http/source/server/HttpServerManager.java
create mode 100644
rocketmq-streams-channel-http/src/main/java/org/apache/rocketmq/streams/http/source/util/HttpUtil.java
copy
rocketmq-streams-dim/src/test/java/com/aliyun/service/ConfigureLoaderTest.java
=>
rocketmq-streams-channel-http/src/test/java/org/apache/rocketmq/streams/http/source/http/HttpChannelTest.java
(51%)
copy {rocketmq-streams-lease => rocketmq-streams-filter}/pom.xml (58%)
create mode 100644 rocketmq-streams-filter/rocketmq-streams-filter.iml
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/FilterComponent.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/builder/ExpressionBuilder.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/builder/RuleBuilder.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/builder/RuleElementBuilder.java
copy
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/strategy/StateStrategy.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/contants/RuleElementType.java
(51%)
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/contants/RuleStatus.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/context/ContextConfigure.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/context/RuleContext.java
copy
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/window/TumblingWindow.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/context/RuleMessage.java
(51%)
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/engine/IRuleEngine.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/engine/SplitFlow.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/engine/impl/DefaultRuleEngine.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/exception/RegexTimeoutException.java
copy
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/function/script/IntelligenceNameListFunction.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/etl/RenameFunction.java
(57%)
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/AbstractExpressionFunction.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/CompareFunction.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/ContainsCaseInsensitiveFunction.java
copy
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/function/expression/NotInExpressionResource.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/ContainsFunction.java
(56%)
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/Equals.java
copy
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/window/TumblingWindow.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/ExpressionFunction.java
(62%)
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/GreaterEquals.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/GreaterThan.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/InFunction.java
copy
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/function/expression/NotInExpressionResource.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/InMetaData.java
(54%)
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/IpContainsFunction.java
copy
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/function/expression/NotInExpressionResource.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/IsNotNull.java
(64%)
copy
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/function/expression/NotInExpressionResource.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/IsNull.java
(64%)
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/LessEquals.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/LessThan.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/LikeFunction.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/NotContainsCaseInsensitiveFunction.java
copy
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/function/expression/NotInExpressionResource.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/NotContainsFunction.java
(54%)
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/NotEquals.java
copy
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/function/expression/NotInExpressionResource.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/NotInFunction.java
(68%)
copy
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/function/expression/NotInExpressionResource.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/NotLikeFunction.java
(69%)
copy
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/function/expression/NotInExpressionResource.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/NotRegexCaseInsensitiveFunction.java
(69%)
copy
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/function/expression/NotInExpressionResource.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/NotRegexFunction.java
(69%)
copy
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/function/expression/NotInExpressionResource.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/RegexCaseInsensitiveFunction.java
(69%)
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/RegexFunction.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/ScriptFunction.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/script/CaseFunction.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/monitor/Monitor.java
copy
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/strategy/StateStrategy.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/monitor/contants/MonitorType.java
(59%)
copy
rocketmq-streams-dim/src/test/java/com/aliyun/service/TableCompressTest.java =>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/monitor/rule/ActionMonitor.java
(71%)
copy
rocketmq-streams-dim/src/test/java/com/aliyun/service/TableCompressTest.java =>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/monitor/rule/ExpressionMonitor.java
(70%)
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/monitor/rule/MessageMonitor.java
copy
rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/SplitBySerialNumber.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/monitor/rule/NullMonitor.java
(56%)
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/monitor/rule/RuleMonitor.java
copy
rocketmq-streams-dim/src/test/java/com/aliyun/service/TableCompressTest.java =>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/monitor/rule/VarMonitor.java
(71%)
copy
rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/StreamBuilder.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/FilterOperator.java
(71%)
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/Rule.java
copy
rocketmq-streams-dim/src/test/java/com/aliyun/service/TableCompressTest.java =>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/action/Action.java
(66%)
copy
rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/driver/IDriverBudiler.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/action/IConfigurableAction.java
(54%)
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/action/impl/ChannelAction.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/action/impl/MetaDataAction.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/Expression.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/ExpressionPerformance.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/ExpressionRelationParser.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/ExpressionRelationPaser.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/GroupExpression.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/GroupExpressionManager.java
copy
rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/driver/batchloader/IRowOperator.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/OptimizationRule.java
(72%)
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/RelationExpression.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/SimpleExpression.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/var/ConstantVar.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/var/ContextVar.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/var/InnerVar.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/var/Var.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/EqualsExpressionOptimization.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/ExpressionOptimization.java
copy
rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/driver/IDriverBudiler.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/IExpressionOptimization.java
(64%)
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/LikeExpressionOptimization.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/OptimizationExpression.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/PiplineLogFingerprintAnalysis.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/RegexExpressionOptimization.java
copy
rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/driver/IDriverBudiler.java
=>
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/service/IRuleEngineService.java
(53%)
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/service/impl/RuleEngineServiceImpl.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/utils/IPUtil.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/utils/RegexUtil.java
copy
rocketmq-streams-dim/src/test/java/com/aliyun/service/ConfigureLoaderTest.java
=>
rocketmq-streams-filter/src/test/java/org/apache/rocketmq/streams/filter/FilterComponentTest.java
(54%)
copy
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/FilterTest.java
=>
rocketmq-streams-filter/src/test/java/org/apache/rocketmq/streams/filter/operator/ExpressionTest.java
(53%)
create mode 100644
rocketmq-streams-filter/src/test/java/org/apache/rocketmq/streams/filter/operator/RuleTest.java
create mode 100644
rocketmq-streams-filter/src/test/resources/credible/ChannelComponent.xml
create mode 100755
rocketmq-streams-filter/src/test/resources/credible/credible-channel.properties
create mode 100755
rocketmq-streams-filter/src/test/resources/credible/credible.properties
copy {rocketmq-streams-transport-minio =>
rocketmq-streams-filter}/src/test/resources/log4j.xml (100%)
copy {rocketmq-streams-transport-minio => rocketmq-streams-schedule}/pom.xml
(68%)
create mode 100644 rocketmq-streams-schedule/rocketmq-streams-schedule.iml
copy
rocketmq-streams-dim/src/main/java/org/apache/rocketmq/streams/dim/DimComponent.java
=>
rocketmq-streams-schedule/src/main/java/org/apache/rocketmq/streams/schedule/ScheduleComponent.java
(52%)
create mode 100644
rocketmq-streams-schedule/src/main/java/org/apache/rocketmq/streams/schedule/job/ConfigurableExecutorJob.java
create mode 100644
rocketmq-streams-schedule/src/main/java/org/apache/rocketmq/streams/schedule/service/IScheduleService.java
create mode 100644
rocketmq-streams-schedule/src/main/java/org/apache/rocketmq/streams/schedule/service/impl/ScheduleServiceImpl.java
create mode 100644
rocketmq-streams-schedule/src/test/java/org/apache/rocketmq/stream/schedule/ScheduleComponentTest.java
copy {rocketmq-streams-transport-minio =>
rocketmq-streams-schedule}/src/test/resources/log4j.xml (100%)
