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 eaad138 Enable test default
new 585a72d modify some error or code style
new 80b711e roll back
new 94ce208 merge
new 4bba6a6 remove redundancy code
new 472e238 Merge branch 'apache:main' into main
new 72385fd merge
new 8582d04 Merge remote-tracking branch 'upstream/main'
new aaabe19 Merge pull request #39 from ni-ze/main
The 113 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:
.../streams/db/sink/SelfMultiTableSink.java | 4 +-
.../rocketmq/streams/source/RocketMQSource.java | 64 ++++++++++++----------
.../streams/client/source/DataStreamSource.java | 12 +---
.../streams/client/transform/DataStream.java | 8 +++
.../common/channel/impl/memory/MemorySink.java | 4 +-
.../common/channel/impl/memory/MemorySource.java | 4 +-
...java => IAfterConfigurableRefreshListener.java} | 2 +-
.../streams/common/functions/FilterFunction.java | 4 +-
.../streams/common/functions/FlatMapFunction.java | 2 +-
.../streams/common/functions/Function.java | 4 +-
.../streams/common/functions/MapFunction.java | 4 +-
.../streams/common/functions/ReduceFunction.java | 4 +-
.../AbstractMutilPipelineChainPipline.java | 4 +-
.../streams/common/topology/ChainPipeline.java | 10 ++--
.../common/topology/builder/PipelineBuilder.java | 17 +++---
.../topology/stages/AbstractWindowStage.java | 10 +---
.../common/topology/stages/FilterChainStage.java | 4 +-
.../common/topology/stages/NewSQLChainStage.java | 4 +-
.../common/topology/stages/OpenAPIChainStage.java | 4 +-
.../common/topology/stages/OutputChainStage.java | 4 +-
.../common/topology/stages/PythonChainStage.java | 4 +-
.../topology/stages/RightJoinChainStage.java | 4 +-
.../common/topology/stages/SQLChainStage.java | 4 +-
.../common/topology/stages/ScriptChainStage.java | 4 +-
.../topology/stages/SubPiplineChainStage.java | 4 +-
.../common/topology/stages/WindowChainStage.java | 4 +-
.../common/topology/stages/udf/StageBuilder.java | 7 +--
.../common/topology/stages/udf/UDFChainStage.java | 4 +-
.../topology/stages/udf/UDFUnionChainStage.java | 4 +-
.../service/AbstractConfigurableService.java | 6 +-
.../service/AbstractConfigurableService.java | 6 +-
.../intelligence/AbstractIntelligenceCache.java | 4 +-
.../dim/intelligence/AccountIntelligenceCache.java | 4 +-
.../dim/intelligence/DomainIntelligenceCache.java | 4 +-
.../dim/intelligence/IPIntelligenceCache.java | 4 +-
.../dim/intelligence/URLIntelligenceCache.java | 4 +-
.../rocketmqsource/RocketMQSourceExample2.java | 6 +-
.../rocketmq/streams/filter/operator/Rule.java | 4 +-
.../filter/operator/action/impl/ChannelAction.java | 4 +-
.../script/operator/impl/FunctionScript.java | 4 +-
.../window/operator/AbstractShuffleWindow.java | 4 +-
41 files changed, 125 insertions(+), 141 deletions(-)
rename
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configurable/{IAfterConfiguableRefreshListerner.java
=> IAfterConfigurableRefreshListener.java} (95%)
