You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2021/08/04 11:16:22 UTC
[rocketmq-streams] 29/42: Merge pull request #4 from speak2me/main
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 177cc756b595932dcbe17ca14bfb09f7381c903d
Merge: 5ef7b1d c41c825
Author: rongtong <ji...@163.com>
AuthorDate: Mon Aug 2 19:13:41 2021 +0800
Merge pull request #4 from speak2me/main
add filter channel-http schedule modules
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 | 45 ++
rocketmq-streams-filter/pom.xml | 31 ++
.../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 | 43 ++
.../streams/filter/contants/RuleStatus.java | 98 ++++
.../streams/filter/context/ContextConfigure.java | 272 ++++++++++
.../streams/filter/context/RuleContext.java | 399 ++++++++++++++
.../streams/filter/context/RuleMessage.java | 48 ++
.../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 | 37 ++
.../expression/AbstractExpressionFunction.java | 67 +++
.../function/expression/CompareFunction.java | 74 +++
.../ContainsCaseInsensitiveFunction.java | 74 +++
.../function/expression/ContainsFunction.java | 62 +++
.../streams/filter/function/expression/Equals.java | 166 ++++++
.../function/expression/ExpressionFunction.java | 33 ++
.../filter/function/expression/GreaterEquals.java | 163 ++++++
.../filter/function/expression/GreaterThan.java | 132 +++++
.../filter/function/expression/InFunction.java | 85 +++
.../filter/function/expression/InMetaData.java | 65 +++
.../function/expression/IpContainsFunction.java | 180 +++++++
.../filter/function/expression/IsNotNull.java | 50 ++
.../streams/filter/function/expression/IsNull.java | 49 ++
.../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 | 63 +++
.../filter/function/expression/NotEquals.java | 169 ++++++
.../filter/function/expression/NotInFunction.java | 35 ++
.../function/expression/NotLikeFunction.java | 36 ++
.../NotRegexCaseInsensitiveFunction.java | 36 ++
.../function/expression/NotRegexFunction.java | 36 ++
.../expression/RegexCaseInsensitiveFunction.java | 41 ++
.../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 | 40 ++
.../streams/filter/monitor/rule/ActionMonitor.java | 27 +
.../filter/monitor/rule/ExpressionMonitor.java | 27 +
.../filter/monitor/rule/MessageMonitor.java | 119 +++++
.../streams/filter/monitor/rule/NullMonitor.java | 55 ++
.../streams/filter/monitor/rule/RuleMonitor.java | 62 +++
.../streams/filter/monitor/rule/VarMonitor.java | 27 +
.../streams/filter/operator/FilterOperator.java | 31 ++
.../rocketmq/streams/filter/operator/Rule.java | 538 +++++++++++++++++++
.../streams/filter/operator/action/Action.java | 28 +
.../operator/action/IConfigurableAction.java | 41 ++
.../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 | 28 +
.../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 | 38 ++
.../optimization/LikeExpressionOptimization.java | 39 ++
.../optimization/OptimizationExpression.java | 71 +++
.../PiplineLogFingerprintAnalysis.java | 433 +++++++++++++++
.../optimization/RegexExpressionOptimization.java | 39 ++
.../streams/filter/service/IRuleEngineService.java | 50 ++
.../filter/service/impl/RuleEngineServiceImpl.java | 104 ++++
.../rocketmq/streams/filter/utils/IPUtil.java | 209 ++++++++
.../rocketmq/streams/filter/utils/RegexUtil.java | 211 ++++++++
.../streams/filter/FilterComponentTest.java | 36 ++
.../streams/filter/operator/ExpressionTest.java | 49 ++
.../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 | 20 +
rocketmq-streams-schedule/pom.xml | 33 ++
.../rocketmq-streams-schedule.iml | 65 +++
.../streams/schedule/ScheduleComponent.java | 65 +++
.../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 | 20 +
103 files changed, 11599 insertions(+)