rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From duhengfore...@apache.org
Subject [rocketmq-streams] branch main updated (2532777 -> 1bbacfc)
Date Sat, 04 Sep 2021 03:59:37 GMT
This is an automated email from the ASF dual-hosted git repository.

duhengforever pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git.


    from 2532777  Merge pull request #46 from yuanxiaodong/window
     new cd6743f  add cache filter to excute quickly for script
     new a961f27  sink support sql cache than can batch submit sqls
     new cfe9573  add transit source and sink to support merge same source sql
     new 8b2a0d9  Merge branch 'main' of https://github.com/apache/rocketmq-streams into window
     new 1bbacfc  Merge pull request #49 from yuanxiaodong/window

The 131 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:
 .../apache/rocketmq/streams/db/sink/DBSink.java    |  49 ++++-
 .../streams/client/strategy/WindowStrategy.java    |   7 +-
 .../streams/client/transform/DataStream.java       |  10 +
 .../streams/client/ScriptOptimizationTest.java     |  16 ++
 .../apache/rocketmq/streams/client/SourceTest.java |  11 +
 .../streams/client/windows/AbstractWindowTest.java |   4 +-
 .../streams/common/cache/compress/BitSetCache.java |  11 +-
 .../streams/common/channel/AbstractChannel.java    |   8 +
 .../impl/transit/TransitChannelBuilder.java        |  52 +++++
 .../common/channel/impl/transit/TransitSink.java   | 226 +++++++++++++++++++++
 .../common/channel/impl/transit/TransitSource.java |  49 +++++
 .../streams/common/channel/sink/AbstractSink.java  |  18 +-
 .../streams/common/channel/sink/ISink.java         |  15 ++
 ...he.java => AbstractMultiSplitMessageCache.java} |   4 +-
 .../sinkcache/impl/MultiSplitMessageCache.java     |   2 +-
 .../sinkcache/impl/MutilSplitMessageCache.java     |  33 ---
 .../streams/common/context/AbstractContext.java    |  23 +++
 .../cachefilter/AbstractCacheFilter.java           |  33 +++
 .../cachefilter/CacheFilterFactory.java            |  47 +++++
 .../optimization/cachefilter/CacheFilterGroup.java |  64 ++++++
 .../cachefilter/CacheFilterManager.java            |  35 ++++
 .../optimization/cachefilter/ICacheFilter.java     |  33 +++
 .../cachefilter/ICacheFilterBulider.java           |  23 +++
 .../common/topology/builder/PipelineBuilder.java   |   3 +-
 .../streams/common/topology/model/IWindow.java     |   1 -
 .../common/topology/stages/OutputChainStage.java   |   2 +-
 .../rocketmq/streams/common/utils/ReflectUtil.java |  10 +
 .../filter/function/expression/LikeFunction.java   |   7 +-
 .../filter/function/expression/RegexFunction.java  |   6 +
 .../filter/function/script/CaseFunction.java       |  10 +
 .../filter/operator/expression/Expression.java     |   9 +-
 .../optimization/AbstractExpressionProxy.java      |  53 +++++
 .../streams/filter/optimization/CaseProxy.java     |  80 ++++++++
 .../filter/optimization/EqualsExpressionProxy.java |  16 ++
 .../optimization/ExpressionProxyFactory.java       |  44 ++++
 .../filter/optimization/LikeExpressionProxy.java   |  16 ++
 .../filter/optimization/RegexExpressionProxy.java  |  17 ++
 .../function/impl/flatmap/SplitArrayFunction.java  |   3 +
 .../script/function/impl/string/RegexFunction.java |   5 +
 .../operator/expression/GroupScriptExpression.java |   6 +
 .../operator/expression/ScriptExpression.java      |   2 +-
 .../script/operator/impl/FunctionScript.java       |   7 +-
 .../optimization/AbstractFunctionOptimization.java |  47 -----
 .../script/optimization/EqualsOptimization.java    |  44 ----
 .../script/optimization/IFunctionOptimization.java |  38 ----
 .../optimization/OptimizationScriptExpression.java |  67 ------
 .../script/optimization/RegexOptimization.java     |  43 ----
 .../{ => compile}/CompileParameter.java            |   2 +-
 .../{ => compile}/CompileScriptExpression.java     |   2 +-
 .../performance/AbstractScriptProxy.java           |  67 ++++++
 .../performance/CaseScriptExpressionProxy.java     |  52 +++++
 .../optimization/performance/EqualsProxy.java      |  29 +++
 .../optimization/performance/RegexProxy.java       |  30 +++
 .../performance/ScriptExpressionGroupsProxy.java   |  71 +++++++
 .../{ => performance}/ScriptOptimization.java      | 215 ++++++--------------
 .../performance/ScriptProxyFactory.java            |  44 ++++
 .../performance/SimpleScriptExpressionProxy.java   |  58 ++++++
 .../parser/imp/ConditionExpressionParser.java      |   1 +
 .../streams/window/debug/DebugAnalysis.java        |   4 +-
 .../rocketmq/streams/window/model/WindowCache.java |   7 +-
 .../streams/window/shuffle/ShuffleCache.java       |   4 +-
 .../streams/window/source/WindowRireSource.java    |   8 +-
 .../rocketmq/streams/window/sqlcache/SQLCache.java |   8 +-
 63 files changed, 1440 insertions(+), 471 deletions(-)
 create mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/ScriptOptimizationTest.java
 create mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/transit/TransitChannelBuilder.java
 create mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/transit/TransitSink.java
 create mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/transit/TransitSource.java
 rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/sinkcache/impl/{AbstractMutilSplitMessageCache.java
=> AbstractMultiSplitMessageCache.java} (98%)
 delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/sinkcache/impl/MutilSplitMessageCache.java
 create mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/cachefilter/AbstractCacheFilter.java
 create mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/cachefilter/CacheFilterFactory.java
 create mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/cachefilter/CacheFilterGroup.java
 create mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/cachefilter/CacheFilterManager.java
 create mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/cachefilter/ICacheFilter.java
 create mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/cachefilter/ICacheFilterBulider.java
 create mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/AbstractExpressionProxy.java
 create mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/CaseProxy.java
 create mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/EqualsExpressionProxy.java
 create mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/ExpressionProxyFactory.java
 create mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/LikeExpressionProxy.java
 create mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/RegexExpressionProxy.java
 delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/AbstractFunctionOptimization.java
 delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/EqualsOptimization.java
 delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/IFunctionOptimization.java
 delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/OptimizationScriptExpression.java
 delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/RegexOptimization.java
 rename rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/{
=> compile}/CompileParameter.java (98%)
 rename rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/{
=> compile}/CompileScriptExpression.java (98%)
 create mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/performance/AbstractScriptProxy.java
 create mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/performance/CaseScriptExpressionProxy.java
 create mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/performance/EqualsProxy.java
 create mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/performance/RegexProxy.java
 create mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/performance/ScriptExpressionGroupsProxy.java
 rename rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/{
=> performance}/ScriptOptimization.java (63%)
 create mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/performance/ScriptProxyFactory.java
 create mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/performance/SimpleScriptExpressionProxy.java

Mime
View raw message