rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ser...@apache.org
Subject [rocketmq-streams] branch async-ck updated (a897b47 -> e7d7136)
Date Thu, 16 Sep 2021 08:52:37 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from a897b47  a runnable window example reading data from rocketmq. (#54)
     new ae3396b  add logfinger filter strategy fixed bugs for sink batch insert
     new ccb119a  Merge branch 'async-ck' of https://github.com/apache/rocketmq-streams into
window
     new 7752a44  add update logic for the DBSinker 、 upgrade the concat_ws function (#57)
     new 0742cf4  Joinwindow bug fix (#61)
     new 87a3222  Add Sqlmode  (#63)
     new c80ab6e  pull from apache
     new bb22e67  fixed bugs
     new e7d7136  Merge pull request #67 from yuanxiaodong/window

The 141 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:
 pom.xml                                            |   2 +-
 .../apache/rocketmq/streams/db/sink/DBSink.java    | 190 ++++++++++++---------
 .../rocketmq/streams/db/sink/DBSinkBuilder.java    |  31 +---
 .../rocketmq/streams/client/DataStreamAction.java  |  21 +++
 ...owStrategy.java => LogFingerprintStrategy.java} |  40 ++---
 .../streams/client/transform/DataStream.java       |  70 ++++----
 .../client/transform/window/HoppingWindow.java     |   5 +-
 .../apache/rocketmq/streams/client/SourceTest.java |   8 +
 .../common/cache/compress/AdditionStore.java       |   7 +-
 .../streams/common/cache/compress/BitSetCache.java |  92 +++++-----
 .../streams/common/cache/compress/ByteArray.java   |  13 +-
 .../common/cache/compress/ByteArrayValueKV.java    |   9 +-
 .../streams/common/cache/compress/CacheKV.java     |  18 +-
 .../streams/common/cache/compress/ICacheKV.java    |   1 -
 .../streams/common/cache/compress/KVElement.java   |   2 +-
 .../cache/compress/impl/FixedLenRowCacheKV.java    |   4 +-
 .../common/cache/compress/impl/IntValueKV.java     |   8 +-
 .../common/cache/compress/impl/LongValueKV.java    |  67 ++++++++
 .../common/cache/compress/impl/MutilValueKV.java   |  46 +++--
 .../AbstractSupportShuffleChannelBuilder.java      |   2 +-
 .../common/channel/impl/OutputPrintChannel.java    |   7 +-
 .../streams/common/channel/sink/AbstractSink.java  |  35 ++--
 .../channel/sink/AbstractSupportShuffleSink.java   |   6 +-
 .../common/channel/source/AbstractSource.java      |  10 ++
 .../streams/common/context/AbstractContext.java    |  19 ++-
 .../streams/common/metadata/AbstractMetaData.java  |   2 +-
 .../rocketmq/streams/common/metadata/MetaData.java |   2 +-
 .../streams/common/metadata/MetaDataField.java     |  32 ++--
 .../common/optimization/HyperscanRegex.java        |  64 +++++--
 .../streams/common/optimization/LikeRegex.java     |  68 +++++++-
 .../common/optimization/LogFingerprintFilter.java  |   3 +-
 .../common/optimization/OptimizationRegex.java     |   6 +-
 .../optimization/cachefilter/CacheFilterGroup.java |  36 ++--
 .../cachefilter/CacheFilterManager.java            |  19 ++-
 .../optimization/cachefilter/CacheFilterMeta.java  |  43 +++++
 .../optimization/cachefilter/ICacheFilter.java     |   6 +
 .../streams/common/topology/ChainPipeline.java     |  95 +++++++++--
 .../streams/common/topology/ChainStage.java        |   4 +-
 .../common/topology/model/AbstractStage.java       |   7 +-
 .../common/topology/stages/OutputChainStage.java   |  53 +++---
 .../rocketmq/streams/common/utils/ReflectUtil.java |   3 +
 .../rocketmq/streams/common/utils/SQLUtil.java     |  54 +++---
 .../service/AbstractConfigurableService.java       |   6 +-
 .../streams/filter/context/RuleContext.java        |   2 +-
 .../filter/engine/impl/DefaultRuleEngine.java      |   2 +-
 .../rocketmq/streams/filter/operator/Rule.java     |   4 +-
 .../filter/operator/expression/Expression.java     |  11 ++
 .../operator/expression/GroupExpression.java       |  13 +-
 .../expression/GroupExpressionManager.java         |  15 +-
 .../optimization/AbstractExpressionProxy.java      |   4 +-
 .../filter/optimization/EqualsExpressionProxy.java |   4 +
 .../filter/optimization/LikeExpressionProxy.java   |   1 +
 .../PiplineLogFingerprintAnalysis.java             |   5 +-
 .../lease/service/storages/DBLeaseStorage.java     |   1 +
 .../rocketmq/streams/lease/LeaseComponentTest.java |   4 +-
 .../streams/script/context/FunctionContext.java    |   2 +-
 .../script/function/impl/field/FieldFunction.java  |  48 +++---
 .../function/impl/flatmap/SplitArrayFunction.java  |   4 +-
 .../function/impl/json/JsonValueFunction.java      |   3 +
 .../impl/string/SubStringIndexFunction.java        |   6 +
 .../script/operator/impl/FunctionScript.java       |   5 +-
 .../performance/AbstractScriptProxy.java           |  11 +-
 .../performance/CaseScriptExpressionProxy.java     |  31 ++--
 .../optimization/performance/EqualsProxy.java      |   5 +-
 .../optimization/performance/RegexProxy.java       |   8 +-
 .../performance/ScriptExpressionGroupsProxy.java   |  63 +++----
 .../performance/ScriptOptimization.java            |  41 ++---
 .../performance/ScriptProxyFactory.java            |  26 ++-
 .../performance/SimpleScriptExpressionProxy.java   |  10 +-
 .../script/service/impl/ScriptServiceImpl.java     |   3 +
 .../streams/script/service/udf/UDAFScript.java     |   4 -
 .../streams/window/model/WindowInstance.java       |   4 +
 .../streams/window/operator/AbstractWindow.java    |   4 +-
 .../streams/window/operator/impl/OverWindow.java   |   2 +-
 .../streams/window/operator/join/JoinWindow.java   | 157 +++++++++++------
 .../streams/window/shuffle/ShuffleChannel.java     |   3 +-
 .../rocketmq/streams/window/sqlcache/SQLCache.java |   3 +-
 .../streams/window/state/impl/WindowValue.java     |   2 +-
 78 files changed, 1095 insertions(+), 632 deletions(-)
 copy rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/strategy/{WindowStrategy.java
=> LogFingerprintStrategy.java} (64%)
 create mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/impl/LongValueKV.java
 create mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/cachefilter/CacheFilterMeta.java

Mime
View raw message