This is an automated email from the ASF dual-hosted git repository.
karp pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git
from b654e661 Merge pull request #132 from ni-ze/replaceDB
new 93d7f775 ConfigurableComponent insert and query
new 2db9d367 add kafka module
new f65653fd add kafka module
new 4565739b add licence for some files
new 93326356 Merge pull request #137 from program-0/snapshot-1.0.2
new 7ef9c4f4 SDK增加udaf的支持
new 0971df8d SDK增加UDAF的支持
new 6664b4b5 GitBook: [#2] No subject
new 713e32b2 GitBook: [#3] No subject
new 6874f5a9 Merge branch 'snapshot-1.0.2' of
https://github.com/j-j-cheng/rocketmq-streams into snapshot-1.0.2
new 32152877 SDK增加udaf的支持
new 829b09e7 SDK增加udaf的支持
new 56c1135d snapshot 1.0.3
new a740bdd6 Snapshot 1.0.2 (#148)
new e4cfdb76 Merge branch 'snapshot-1.0.3' of
https://github.com/apache/rocketmq-streams into snapshot-1.0.3
new cd005973 构建snapshot1.0.3
new 64cdd64c 构建snapshot1.0.3
new 1cd2dd02 Merge pull request #157 from j-j-cheng/snapshot-1.0.3
new f5a1380f merge 0.1
new 9d3ae58b merge 1.0
new a5a6ddde merge from snapshot-1.0.3
new a5396881 merge from upstream/snapshot-1.0.3
new 840c956f feat(db) remove db dependency besides channel-db
new ef6f7cf6 Merge branch 'replaceDB' into devForEnterprise
new 5e91a37a 1.0.2-preview-SNAPSHOT -> 1.0.3-preview-SNAPSHOT
new ff92d26b fix(example) join example
new f1d507c0 Merge branch 'replaceDB' into devForEnterprise
new 4d94b411 make FileSourceExample runnable
new 5a236975 fix(example) join example
new 0bcaf5bf modify topic
new 24b5bf90 remove mini batch
new aadf7eaa make RocketMQWindowExample runnable
new 42abb209 merge from replaceDB
new bc38da9f Merge branch 'main' into snapshot-1.0.4
new ce2f98bd merge from main
new f99c509b Merge pull request #186 from ni-ze/snapshot-1.0.4
The 523 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 | 124 ++----
rocketmq-streams-channel-db/pom.xml | 4 +-
.../streams/db/sink/AbstractMultiTableSink.java | 12 +-
.../streams/db/sink/DynamicMultipleDBSink.java | 11 +-
.../streams/db/sink/SelfMultiTableSink.java | 2 +-
.../streams/db/sink/SplitBySerialNumber.java | 2 +-
.../streams/db/sink/SplitByTimeMultiTableSink.java | 2 +-
rocketmq-streams-channel-es/pom.xml | 27 +-
.../rocketmq/streams/es/sink/ESChannelBuilder.java | 46 +-
.../rocketmq/streams/es/sink/ESSinkBuilder.java | 1 +
.../streams/es/sink/ESSinkOnlyChannel.java | 43 +-
.../apache/rocketmq/streams/es/sink/EsClient.java | 135 ++++++
rocketmq-streams-channel-http/pom.xml | 4 +-
rocketmq-streams-channel-mqtt/pom.xml | 20 +-
.../rocketmq/streams/mqtt/source/PahoSource.java | 41 +-
rocketmq-streams-channel-rocketmq/pom.xml | 28 +-
.../apache/rocketmq/streams/debug/DebugWriter.java | 92 ++--
.../apache/rocketmq/streams/sink/RocketMQSink.java | 17 +-
.../rocketmq/streams/RocketMQChannelTest.java | 2 +-
rocketmq-streams-channel-syslog/pom.xml | 19 +-
.../rocketmq/streams/syslog/SyslogChannel.java | 35 +-
.../streams/syslog/SyslogChannelBuilder.java | 4 +
.../streams/syslog/SyslogChannelManager.java | 6 +-
.../rocketmq/streams/syslog/SyslogServer.java | 35 +-
.../rocketmq/streams/syslog/SyslogClient.java | 22 +-
rocketmq-streams-clients/pom.xml | 10 +-
.../streams/client/source/DataStreamSource.java | 19 +
.../streams/client/transform/DataStream.java | 41 +-
.../streams/client/transform/JoinStream.java | 5 +-
.../streams/client/transform/SplitStream.java | 24 +-
.../streams/client/transform/WindowStream.java | 50 ++-
.../client/transform/window/WindowInfo.java | 3 +-
.../rocketmq/streams/client/ApplicationTest.java | 57 +++
.../rocketmq/streams/client/DBDriverTest.java | 27 +-
.../rocketmq/streams/client/MqttSourceExample.java | 80 ++++
.../rocketmq/streams/client/ORMUtilTest.java | 84 ----
.../apache/rocketmq/streams/client}/Person.java | 34 +-
.../client/{SinkTest.java => ScriptTest.java} | 24 +-
.../apache/rocketmq/streams/client/WindowTest.java | 2 +
.../rocketmq/streams/client/example/SplitTest.java | 35 +-
.../streams/client/sink/UserDefinedSink.java | 2 +-
.../client/sink/UserDefinedSupportShuffleSink.java | 4 +-
rocketmq-streams-commons/pom.xml | 46 +-
.../MappedByteBufferTableWithPrimaryIndex.java | 482 +++++++++++++++++++++
.../streams/common/cache/compress/KVAddress.java | 48 +-
.../streams/common/channel/AbstractChannel.java | 14 +-
.../AbstractSupportShuffleChannelBuilder.java | 2 +-
.../common/channel/builder/IChannelBuilder.java | 25 +-
.../channel/builder/IShuffleChannelBuilder.java | 4 +-
...OutputPrintChannel.java => CollectionSink.java} | 31 +-
.../common/channel/impl/CollectionSinkBuilder.java | 30 +-
.../common/channel/impl/PrintChannelBuilder.java | 26 +-
.../channel/impl/file/FileChannelBuilder.java | 45 +-
.../streams/common/channel/impl/file/FileSink.java | 4 +-
.../common/channel/impl/file/FileSource.java | 2 +-
.../channel/impl/memory/MemoryChannelBuilder.java | 34 +-
.../common/channel/impl/memory/MemorySink.java | 4 +-
.../channel/impl/view/ViewChannelBuilder.java | 51 +--
.../impl/view/ViewSink.java} | 29 +-
.../common/channel/impl/view/ViewSource.java | 36 +-
.../streams/common/channel/sink/AbstractSink.java | 17 +-
.../channel/sink/AbstractSupportShuffleSink.java | 8 +-
.../sink/AbstractSupportShuffleUDFSink.java | 6 +-
.../common/channel/sink/AbstractUDFSink.java | 23 +-
.../streams/common/channel/sink/ISink.java | 9 +-
.../impl/AbstractMultiSplitMessageCache.java | 22 +-
.../common/channel/source/AbstractSource.java | 89 +++-
.../channel/source/AbstractUnreliableSource.java | 2 +-
.../streams/common/channel/split/ISplit.java | 5 +-
.../streams/common/component/ComponentCreator.java | 4 +
.../common/configurable/AbstractConfigurable.java | 17 +-
.../common/configurable/BasedConfigurable.java | 13 +-
.../common/configurable/IConfigurableService.java | 5 +-
.../streams/common/configure/ConfigureFileKey.java | 7 +-
.../streams/common/context/AbstractContext.java | 33 +-
.../streams/common/context/MessageHeader.java | 89 ++--
.../streams/common/datatype/IntDataType.java | 3 +-
.../streams/common/datatype/ShortDataType.java | 2 +-
.../{ISystemMessage.java => ISerialize.java} | 4 +-
.../rocketmq/streams/common/model/NameCreator.java | 14 +-
.../NameCreatorContext.java} | 25 +-
.../common/monitor/ConsoleMonitorManager.java | 412 ++++++++++++++++++
.../streams/common/monitor/DataSyncConstants.java | 54 +++
.../streams/common/monitor/HttpClient.java | 116 +++++
.../rocketmq/streams/common/monitor}/HttpUtil.java | 51 ++-
.../monitor/MonitorDataSyncServiceFactory.java | 61 +++
.../common/monitor/group/MonitorCommander.java | 4 +-
.../streams/common/monitor/impl/DipperMonitor.java | 2 +-
.../streams/common/monitor/model/JobStage.java | 350 +++++++++++++++
.../streams/common/monitor/model/TraceIdsDO.java | 126 ++++++
.../common/monitor/model/TraceMonitorDO.java | 250 +++++++++++
.../service/MonitorDataSyncService.java} | 16 +-
.../service/impl/DBMonitorDataSyncImpl.java | 63 +++
.../service/impl/HttpMonitorDataSyncImpl.java | 151 +++++++
.../service/impl/RocketMQMonitorDataSyncImpl.java | 185 ++++++++
.../optimization/IHomologousOptimization.java | 2 +-
.../common/optimization/MessageGlobleTrace.java | 16 +-
.../streams/common/optimization/Re2Engine.java | 47 +-
.../common/optimization/TaskOptimization.java | 17 +-
.../optimization/fingerprint/FingerprintCache.java | 4 +-
.../optimization/fingerprint/PreFingerprint.java | 54 ++-
.../streams/common/schedule/ScheduleTask.java | 4 +-
.../common/threadpool/ThreadPoolFactory.java | 34 +-
.../AbstractMutilPipelineChainPipline.java | 81 ++--
.../streams/common/topology/ChainPipeline.java | 255 ++++++-----
.../streams/common/topology/ChainStage.java | 32 +-
.../common/topology/builder/PipelineBuilder.java | 139 ++++--
.../common/topology/metric/NotFireReason.java | 176 ++++++++
.../streams/common/topology/metric/StageGroup.java | 248 +++++++++++
.../common/topology/metric/StageMetric.java | 138 ++++++
.../common/topology/model/AbstractStage.java | 177 +++++---
.../streams/common/topology/model/IWindow.java | 3 +-
.../streams/common/topology/model/Pipeline.java | 56 ++-
.../topology/model/PipelineSourceJoiner.java | 48 --
.../topology/shuffle/IShuffleKeyGenerator.java | 7 +-
.../common/topology/shuffle/ShuffleMQCreator.java | 398 ++++++++++-------
.../topology/stages/AbstractWindowStage.java | 5 +-
...atelessChainStage.java => EmptyChainStage.java} | 32 +-
.../common/topology/stages/FilterChainStage.java | 157 ++-----
.../common/topology/stages/JoinChainStage.java | 3 +-
.../stages/JoinEndChainStage.java} | 5 +-
.../topology/stages/JoinStartChainStage.java | 67 +++
.../common/topology/stages/OutputChainStage.java | 81 ++--
.../topology/stages/ShuffleConsumerChainStage.java | 193 +++++++++
.../topology/stages/ShuffleProducerChainStage.java | 345 +++++++++++++++
.../topology/stages/SubPiplineChainStage.java | 138 ------
.../common/topology/stages/UnionChainStage.java | 3 +-
.../stages/UnionEndChainStage.java} | 6 +-
...onChainStage.java => UnionStartChainStage.java} | 43 +-
.../ViewChainStage.java} | 479 ++++++++++----------
.../common/topology/stages/udf/UDFChainStage.java | 27 +-
.../streams/common/topology/task/StreamsTask.java | 444 +++----------------
.../streams/common/topology/task/TaskAssigner.java | 20 +-
.../streams/common/utils/ConfigurableUtil.java | 6 +-
.../streams/common/utils/ContantsUtil.java | 33 +-
.../streams/common/utils/DataTypeUtil.java | 16 +-
.../rocketmq/streams/common/utils/FileUtil.java | 89 +++-
.../streams/common/utils/InstantiationUtil.java | 48 +-
.../streams/common/utils/JsonableUtil.java | 5 +
.../rocketmq/streams/common/utils/KryoUtil.java | 210 +++++++++
.../streams/common/utils/NameCreatorUtil.java | 60 ---
.../streams/common/utils/PipelineHTMLUtil.java | 299 +++++++++++++
.../streams/common/utils/PropertiesUtils.java | 2 +-
.../rocketmq/streams/common/utils/ReflectUtil.java | 64 ++-
.../streams/common/utils/SerializeUtil.java | 17 +-
.../streams/common/utils/ServiceLoadUtil.java | 63 +++
.../rocketmq/streams/common/utils/TraceUtil.java | 23 +-
.../rocketmq/streams/common/channel/SinkTest.java | 4 +-
rocketmq-streams-configurable/pom.xml | 9 +-
.../configurable/ConfigurableComponent.java | 17 +-
.../service/AbstractConfigurableService.java | 98 ++---
.../service/impl}/FileConfigureService.java | 2 +-
.../impl}/FileSupportParentConfigureService.java | 2 +-
.../service/impl/HttpConfigureService.java | 377 ++++++++++++++++
.../impl/HttpSupportParentConfigureService.java | 20 +-
.../service/impl}/MemoryConfigureService.java | 2 +-
.../impl}/MemorySupportParentConfigureService.java | 2 +-
rocketmq-streams-db-operator/pom.xml | 4 +-
.../streams/db/configuable/DBConfigureService.java | 11 +-
rocketmq-streams-examples/pom.xml | 17 +-
.../streams/examples/send/ProducerFromFile.java | 8 +-
rocketmq-streams-filter/pom.xml | 3 +-
.../streams/filter/builder/ExpressionBuilder.java | 49 +--
.../streams/filter/context/RuleContext.java | 32 +-
.../filter/engine/impl/DefaultRuleEngine.java | 29 +-
.../function/expression/CompareFunction.java | 16 +-
.../rocketmq/streams/filter/operator/Rule.java | 58 +++
.../expression/ExpressionRelationParser.java | 9 +-
.../expression/ExpressionRelationPaser.java | 107 -----
.../operator/expression/GroupExpression.java | 3 +-
.../operator/expression/RelationExpression.java | 35 +-
.../PiplineLogFingerprintAnalysis.java | 6 +-
.../dependency/BlinkRuleV2Expression.java | 5 +-
.../optimization/dependency/DependencyTree.java | 22 +-
.../dependency/SimplePipelineTree.java | 3 +-
.../dependency/StateLessDependencyTree.java | 84 ++++
.../optimization/homologous/HomologousCompute.java | 5 +-
.../homologous/HomologousOptimization.java | 13 +-
rocketmq-streams-script/pom.xml | 4 +-
...eAccumulator.java => LastValueAccumulator.java} | 29 +-
.../function/impl/distinct/DistinctFunction.java | 1 -
.../function/impl/json/JsonCreatorFunction.java | 4 +-
.../UDTFFieldNameFunction.java} | 43 +-
.../script/function/impl/parser/GrokFunction.java | 4 +-
.../function/impl/parser/Paser2JsonFunction.java | 17 +-
.../function/impl/parser/PaserBySplitFunction.java | 44 +-
.../function/impl/parser/RegexParserFunction.java | 24 +-
.../script/function/impl/router/RouteFunction.java | 4 +-
.../script/operator/impl/AggregationScript.java | 19 +-
.../streams/script/service/IAccumulator.java | 4 +-
.../script/service/udf/SimpleUDAFScript.java | 26 +-
.../streams/script/service/udf/UDFScript.java | 26 +-
.../streams/script/function/FunctionTest.java | 19 +-
rocketmq-streams-serviceloader/pom.xml | 4 +-
rocketmq-streams-state/pom.xml | 4 +-
.../streams/state/kv/rocksdb/RocksDBOperator.java | 37 +-
rocketmq-streams-transport-minio/pom.xml | 4 +-
rocketmq-streams-window/pom.xml | 9 +-
.../window/minibatch/ShuffleMessageCache.java | 187 ++++++++
.../streams/window/model/WindowInstance.java | 22 +-
.../streams/window/operator/AbstractWindow.java | 73 +++-
.../window/operator/impl/SessionOperator.java | 10 +-
.../window/operator/impl/WindowOperator.java | 8 +-
.../streams/window/operator/join/JoinWindow.java | 12 +-
.../window/shuffle/AbstractSystemChannel.java | 94 ++--
.../streams/window/shuffle/ShuffleCache.java | 14 +-
.../streams/window/shuffle/ShuffleChannel.java | 45 +-
.../streams/window/state/impl/WindowValue.java | 54 ++-
.../streams/window/trigger/WindowTrigger.java | 1 -
.../rocketmq/streams/window/util/ShuffleUtil.java | 62 +++
.../org/apache/rocketmq/streams/RocksdbTest.java | 2 +-
211 files changed, 8161 insertions(+), 3106 deletions(-)
copy
rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/DBSinkBuilder.java
=>
rocketmq-streams-channel-es/src/main/java/org/apache/rocketmq/streams/es/sink/ESChannelBuilder.java
(66%)
create mode 100644
rocketmq-streams-channel-es/src/main/java/org/apache/rocketmq/streams/es/sink/EsClient.java
create mode 100644
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/ApplicationTest.java
create mode 100644
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/MqttSourceExample.java
copy
{rocketmq-streams-db-operator/src/test/java/org/apache/rocketmq/streams/db =>
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client}/Person.java
(69%)
copy
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/{SinkTest.java
=> ScriptTest.java} (63%)
copy
rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/FileSourceExample.java
=>
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/SplitTest.java
(53%)
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/MappedByteBufferTableWithPrimaryIndex.java
copy
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/{OutputPrintChannel.java
=> CollectionSink.java} (64%)
copy
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/sink/UDFDefinedSQLParser.java
=>
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/CollectionSinkBuilder.java
(62%)
copy
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/sink/UDFDefinedSQLParser.java
=>
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/PrintChannelBuilder.java
(61%)
copy
rocketmq-streams-channel-syslog/src/main/java/org/apache/rocketmq/streams/syslog/SyslogChannelBuilder.java
=>
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/file/FileChannelBuilder.java
(66%)
copy
rocketmq-streams-channel-mqtt/src/main/java/org/apache/rocketmq/streams/mqtt/MqttChannelBuilder.java
=>
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/memory/MemoryChannelBuilder.java
(61%)
copy
rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/DBSinkBuilder.java
=>
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/view/ViewChannelBuilder.java
(62%)
copy
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/{topology/model/IStageHandle.java
=> channel/impl/view/ViewSink.java} (63%)
copy
rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/source/UserDefinedSource.java
=>
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/view/ViewSource.java
(53%)
copy
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/interfaces/{ISystemMessage.java
=> ISerialize.java} (96%)
copy
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/{utils/DipperThreadLocalUtil.java
=> model/NameCreatorContext.java} (58%)
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/ConsoleMonitorManager.java
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/DataSyncConstants.java
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/HttpClient.java
copy
{rocketmq-streams-channel-http/src/main/java/org/apache/rocketmq/streams/http/source/util
=>
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor}/HttpUtil.java
(87%)
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/MonitorDataSyncServiceFactory.java
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/model/JobStage.java
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/model/TraceIdsDO.java
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/model/TraceMonitorDO.java
copy
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/{optimization/IHomologousOptimization.java
=> monitor/service/MonitorDataSyncService.java} (63%)
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/service/impl/DBMonitorDataSyncImpl.java
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/service/impl/HttpMonitorDataSyncImpl.java
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/service/impl/RocketMQMonitorDataSyncImpl.java
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/metric/NotFireReason.java
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/metric/StageGroup.java
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/metric/StageMetric.java
delete mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/model/PipelineSourceJoiner.java
copy
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/action/IConfigurableAction.java
=>
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/shuffle/IShuffleKeyGenerator.java
(80%)
copy
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/shuffle/AbstractSystemChannel.java
=>
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/shuffle/ShuffleMQCreator.java
(54%)
copy
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/{AbstractStatelessChainStage.java
=> EmptyChainStage.java} (55%)
copy
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/{utils/RegexUtil.java
=> topology/stages/JoinEndChainStage.java} (87%)
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/JoinStartChainStage.java
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/ShuffleConsumerChainStage.java
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/ShuffleProducerChainStage.java
delete mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/SubPiplineChainStage.java
copy
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/{schedule/IScheduleCondition.java
=> topology/stages/UnionEndChainStage.java} (87%)
copy
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/{UnionChainStage.java
=> UnionStartChainStage.java} (50%)
copy
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/{task/StreamsTask.java
=> stages/ViewChainStage.java} (51%)
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/KryoUtil.java
delete mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/NameCreatorUtil.java
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/PipelineHTMLUtil.java
create mode 100644
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/ServiceLoadUtil.java
rename
{rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/configuable
=>
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/impl}/FileConfigureService.java
(99%)
copy
{rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/configuable
=>
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/impl}/FileSupportParentConfigureService.java
(96%)
create mode 100644
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/impl/HttpConfigureService.java
rename
rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/configuable/FileSupportParentConfigureService.java
=>
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/impl/HttpSupportParentConfigureService.java
(71%)
rename
{rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/configuable
=>
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/impl}/MemoryConfigureService.java
(98%)
rename
{rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/configuable
=>
rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/impl}/MemorySupportParentConfigureService.java
(96%)
delete mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/ExpressionRelationPaser.java
create mode 100644
rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/dependency/StateLessDependencyTree.java
copy
rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/aggregation/{FirstValueAccumulator.java
=> LastValueAccumulator.java} (68%)
copy
rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/{string/ToLowerFunction.java
=> json/UDTFFieldNameFunction.java} (54%)
copy
rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/IChannel.java
=>
rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/service/udf/SimpleUDAFScript.java
(58%)
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/minibatch/ShuffleMessageCache.java
create mode 100644
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/util/ShuffleUtil.java
