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
