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 <[email protected]> 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(+)
