You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ka...@apache.org on 2022/12/18 02:35:49 UTC
[rocketmq-streams] branch main updated (49c70180 -> cdacbf97)
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 49c70180 Update .asf.yaml
new 81097f4b feat(new)optimization
new 27d29d98 add not
new b8251273 remove old
new 238d7d18 feat(streams) support generics; support keyBy; support state store
new ae055da3 temp
new e28b5f95 fix bug:wait->await
new 48bcb844 Merge branch 'newWorld-4' of github.com:ni-ze/rocketmq-streams into newWorld-4
new 4bb4fcde support state
new bd50a889 support state
new 51558ff2 support state
new e40df9ca update store
new 2b5c6415 suport timestap select
new f417764e support window
new 8b64d518 support window
new 64658389 test
new a4049535 support window
new 55966b26 debug
new 8f07ce93 remove note
new ba2ed435 modify method name
new 8412cfca watermark
new 6b65cc1a debug
new 024c39c5 debug
new 5596839a debug
new 4d2c2004 add logger
new ba51c467 sliding window
new c5d18d49 session window
new b1495256 session debug
new 7e941c68 debug
new 6c3862b6 session window
new 1fec2560 update
new 9050e6c4 update
new ea581a3f add job id
new f9713d3d test join
new b7cced03 use jackson
new 445ba00a first join
new c801cfb7 move shuffle into window
new 56a5fdc8 test
new 445ad4ad update forward
new 775055b8 topo ok
new f9e280a9 join 0.1
new f04bd6f5 jackson
new a2268864 test
new b03223c4 serde
new b41d75b4 add interface
new 41afcc9e debug
new fe93223d modify rocksdb
new 38321add modify serde in rocksdb
new 4ce166af debug
new 64b687c0 support join
new 0980e6d0 debug
new 3ae758ba remove action interface
new 5e8ccb32 modify windowkey
new 872588fe add note
new be7b1852 remove userless code
new ffc9079f rename module
new 4ee4dd20 add stop
new 7614545e remove fastjson from core
new c81e6283 create static topic
new 32381974 create shuffle topic
new 7af023ae remove useless debug
new d3e7b0ca create compact topic
new e24ee184 add note
new a605a94e release bytebuf
new aee3569f merge from main
new 54d70e44 delete pic
new dda63aef modify sink
new 0763b382 add license
new cdacbf97 Merge pull request #229 from ni-ze/newWorld-4
The 660 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:
core/pom.xml | 87 +
.../rocketmq/streams/core/RocketMQStream.java | 72 +
.../rocketmq/streams/core/common/Constant.java | 59 +
.../streams/core/function/AggregateAction.java | 10 +-
.../streams/core/function/FilterAction.java | 10 +-
.../streams/core/function/ForeachAction.java | 6 +-
.../streams/core/function/KeySelectAction.java | 6 +-
.../streams/core/function/ValueJoinAction.java | 7 +-
.../streams/core/function/ValueMapperAction.java | 9 +-
.../core/function/supplier/AddTagSupplier.java | 58 +
.../core/function/supplier/AggregateSupplier.java | 100 +
.../core/function/supplier/FilterSupplier.java | 54 +
.../core/function/supplier/ForeachSupplier.java | 54 +
.../supplier/JoinWindowAggregateSupplier.java | 233 +
.../core/function/supplier/KeySelectSupplier.java | 53 +
.../core/function/supplier/PrintSupplier.java | 68 +
.../core/function/supplier/SinkSupplier.java | 106 +
.../core/function/supplier/SourceSupplier.java | 98 +
.../supplier/TimestampSelectorSupplier.java | 53 +
.../function/supplier/ValueChangeSupplier.java | 73 +
.../function/supplier/WindowAggregateSupplier.java | 372 +
.../rocketmq/streams/core/metadata/Data.java | 82 +
.../streams/core/metadata/StreamConfig.java | 38 +-
.../streams/core/rstream/GroupedStream.java | 26 +-
.../streams/core/rstream/GroupedStreamImpl.java | 93 +
.../streams/core/rstream/JoinedStream.java | 147 +
.../rocketmq/streams/core/rstream/Pipeline.java | 95 +
.../rocketmq/streams/core/rstream/RStream.java | 46 +
.../rocketmq/streams/core/rstream/RStreamImpl.java | 155 +
.../streams/core/rstream/StreamBuilder.java | 67 +
.../streams/core/rstream/WindowStream.java | 16 +-
.../streams/core/rstream/WindowStreamImpl.java | 93 +
.../streams/core/running/AbstractProcessor.java | 170 +
.../core/running/AbstractWindowProcessor.java | 47 +
.../core/running/MessageQueueListenerWrapper.java | 108 +
.../rocketmq/streams/core/running/Processor.java | 16 +-
.../streams/core/running/RocketMQClient.java | 65 +
.../streams/core/running/StreamContext.java | 34 +-
.../streams/core/running/StreamContextImpl.java | 135 +
.../apache/rocketmq/streams/core/running/Task.java | 8 +-
.../streams/core/running/WorkerThread.java | 244 +
.../streams/core/runtime/operators/JoinType.java | 6 +-
.../streams/core/runtime/operators/StreamType.java | 8 +-
.../streams/core/runtime/operators/Time.java | 75 +
.../streams/core/runtime/operators/TimeType.java | 8 +-
.../streams/core/runtime/operators/Window.java | 48 +-
.../core/runtime/operators/WindowBuilder.java | 46 +-
.../streams/core/runtime/operators/WindowInfo.java | 103 +
.../streams/core/runtime/operators/WindowKey.java | 115 +
.../core/runtime/operators/WindowState.java | 260 +
.../core/runtime/operators/WindowStore.java | 108 +
.../streams/core/serialization/JsonSerDe.java | 32 +-
.../core/serialization/KeyValueDeserializer.java | 16 +-
.../core/serialization/KeyValueSerializer.java | 10 +-
.../streams/core/serialization/SerDeWrapper.java | 11 +-
.../core/serialization/ShuffleProtocol.java | 76 +
.../serialization/deImpl/KVAvroDeserializer.java | 100 +
.../serialization/deImpl/KVJsonDeserializer.java | 61 +
.../serialization/serImpl/KVAvroSerializer.java | 100 +
.../serialization/serImpl/KVJsonSerializer.java | 54 +
.../rocketmq/streams/core/state/AbstractStore.java | 213 +
.../rocketmq/streams/core/state/RocketMQStore.java | 418 +
.../rocketmq/streams/core/state/RocksDBKey.java | 74 +
.../rocketmq/streams/core/state/RocksDBStore.java | 253 +
.../rocketmq/streams/core/state/StateStore.java | 55 +
.../rocketmq/streams/core/topology/Topology.java | 14 +-
.../streams/core/topology/TopologyBuilder.java | 115 +
.../core/topology/real/ProcessorFactory.java | 41 +-
.../core/topology/real/RealProcessorFactory.java | 10 +-
.../streams/core/topology/real/SinkFactory.java | 30 +-
.../streams/core/topology/real/SourceFactory.java | 32 +-
.../core/topology/virtual/AbstractGraphNode.java | 80 +
.../streams/core/topology/virtual/GraphNode.java | 27 +-
.../core/topology/virtual/ProcessorNode.java | 85 +
.../topology/virtual/ShuffleProcessorNode.java | 55 +
.../core/topology/virtual/SinkGraphNode.java | 38 +-
.../core/topology/virtual/SourceGraphNode.java | 43 +
.../streams/core/util/CommonNameMaker.java | 22 +-
.../streams/core/util/OperatorNameMaker.java | 63 +
.../apache/rocketmq/streams/core/util/Pair.java | 45 +-
.../rocketmq/streams/core/util/RocketMQUtil.java | 162 +
.../apache/rocketmq/streams/core/util/Utils.java | 117 +
core/src/main/resources/logback.xml | 71 +
.../java/org/apache/rocketmq/streams/core/Num.java | 17 +-
.../org/apache/rocketmq/streams/core/Test.java | 5 +-
.../org/apache/rocketmq/streams/core/User.java | 14 +-
.../streams/core/function/AggregateSupplier.java | 100 +
.../streams/core/runtime/WindowStateTests.java | 24 +-
.../streams/core/state/RocksDBStoreTest.java | 75 +
.../rocketmq/streams/core/util/UtilsTests.java | 48 +
docs/SUMMARY.md | 7 -
...225\264\344\275\223\346\236\266\346\236\204.md" | 33 -
.../2.\346\236\204\345\273\272DataStream.md" | 73 -
.../3.\345\220\257\345\212\250DataStream.md" | 53 -
...265\201\350\275\254\350\277\207\347\250\213.md" | 63 -
...256\227\345\255\220\350\247\243\346\236\220.md" | 55 -
"docs/images/Pipeline\347\261\273\345\233\276.png" | Bin 44207 -> 0 bytes
...treams\346\211\251\347\274\251\345\256\271.png" | Bin 142453 -> 0 bytes
docs/images/window.png | Bin 241692 -> 0 bytes
...75\223\346\236\266\346\236\204\345\233\276.png" | Bin 60493 -> 0 bytes
...00\273\344\275\223\350\277\207\347\250\213.png" | Bin 44252 -> 0 bytes
.../\346\211\251\347\274\251\345\256\271.png" | Bin 153620 -> 0 bytes
...12\266\346\200\201\347\256\227\345\255\220.png" | Bin 35766 -> 0 bytes
...66\210\350\264\271\346\250\241\345\236\213.png" | Bin 117975 -> 0 bytes
...12\266\346\200\201\345\255\230\345\202\250.png" | Bin 84924 -> 0 bytes
docs/stream_sink/README.md | 112 -
docs/stream_source/README.md | 101 -
docs/stream_transform/README.md | 242 -
{rocketmq-streams-channel-mqtt => example}/pom.xml | 23 +-
.../rocketmq/streams/examples/WordCount.java | 66 +
.../streams/examples/joinWindow/JoinWindow.java | 97 +
.../rocketmq/streams/examples/pojo/Demo.java | 66 +
.../apache/rocketmq/streams/examples/pojo/Num.java | 56 +-
.../rocketmq/streams/examples/pojo/Union.java | 52 +-
.../rocketmq/streams/examples/pojo/User.java | 39 +-
.../examples/window/SessionWindowCount.java | 65 +
.../streams/examples/window/SlideWindowCount.java | 66 +
.../streams/examples/window/windowCount.java | 75 +
.../streams/examples/window/windowWordCount.java | 70 +
pom.xml | 561 +-
rocketmq-streams-channel-db/pom.xml | 36 -
.../streams/db/DynamicMultipleDBSplit.java | 77 -
.../streams/db/sink/AbstractMultiTableSink.java | 169 -
.../apache/rocketmq/streams/db/sink/DBSink.java | 373 -
.../rocketmq/streams/db/sink/DBSinkBuilder.java | 77 -
.../streams/db/sink/DynamicMultipleDBSink.java | 90 -
.../rocketmq/streams/db/sink/EnhanceDBSink.java | 370 -
.../streams/db/sink/SelfMultiTableSink.java | 53 -
.../streams/db/sink/SplitBySerialNumber.java | 36 -
.../streams/db/sink/SplitByTimeMultiTableSink.java | 36 -
.../streams/db/sink/sqltemplate/ISqlTemplate.java | 50 -
.../MysqlInsertIgnoreIntoSqlTemplate.java | 39 -
.../sqltemplate/MysqlInsertIntoSqlTemplate.java | 66 -
...MysqlInsertIntoWithDuplicateKeySqlTemplate.java | 54 -
.../db/sink/sqltemplate/SqlTemplateFactory.java | 40 -
.../streams/db/sink/db/DBWriteOnlyChannelTest.java | 83 -
.../streams/db/sink/db/ISqlTemplateTest.java | 85 -
rocketmq-streams-channel-es/.gitignore | 1 -
rocketmq-streams-channel-es/pom.xml | 42 -
.../rocketmq/streams/es/sink/ESChannelBuilder.java | 65 -
.../rocketmq/streams/es/sink/ESSinkBuilder.java | 80 -
.../streams/es/sink/ESSinkOnlyChannel.java | 274 -
.../apache/rocketmq/streams/es/sink/EsClient.java | 135 -
.../rocketmq/streams/db/sink/es/EsChannelTest.java | 52 -
rocketmq-streams-channel-http/pom.xml | 46 -
.../rocketmq/streams/http/source/HttpSource.java | 156 -
.../streams/http/source/server/HttpServer.java | 269 -
.../http/source/server/HttpServerManager.java | 59 -
.../streams/http/source/util/HttpUtil.java | 249 -
.../streams/http/source/http/HttpChannelTest.java | 45 -
.../rocketmq/streams/mqtt/MqttChannelBuilder.java | 60 -
.../rocketmq/streams/mqtt/sink/PahoSink.java | 161 -
.../rocketmq/streams/mqtt/source/PahoSource.java | 277 -
.../org/apache/rocketmq/streams/mqtt/PahoTest.java | 108 -
rocketmq-streams-channel-rocketmq/pom.xml | 72 -
.../rocketmq/streams/RocketMQChannelBuilder.java | 98 -
.../apache/rocketmq/streams/debug/DebugWriter.java | 126 -
.../streams/queue/RocketMQMessageQueue.java | 119 -
.../rocketmq/streams/schema/AvroSchemaWrapper.java | 73 -
.../streams/schema/CustomSchemaWrapper.java | 53 -
.../rocketmq/streams/schema/JsonSchemaWrapper.java | 77 -
.../rocketmq/streams/schema/SchemaConfig.java | 124 -
.../apache/rocketmq/streams/schema/SchemaType.java | 52 -
.../rocketmq/streams/schema/SchemaWrapper.java | 27 -
.../streams/schema/SchemaWrapperFactory.java | 57 -
.../apache/rocketmq/streams/sink/RocketMQSink.java | 355 -
.../streams/source/MessageListenerDelegator.java | 80 -
.../rocketmq/streams/source/RocketMQSource.java | 412 -
.../rocketmq/streams/AbstractChannelTest.java | 58 -
.../rocketmq/streams/RocketMQChannelTest.java | 178 -
rocketmq-streams-channel-syslog/.gitignore | 1 -
rocketmq-streams-channel-syslog/pom.xml | 33 -
.../rocketmq/streams/syslog/ISyslogRouter.java | 28 -
.../rocketmq/streams/syslog/SyslogChannel.java | 329 -
.../streams/syslog/SyslogChannelBuilder.java | 87 -
.../streams/syslog/SyslogChannelManager.java | 103 -
.../rocketmq/streams/syslog/SyslogParser.java | 95 -
.../rocketmq/streams/syslog/SyslogServer.java | 277 -
.../rocketmq/streams/syslog/SyslogClient.java | 78 -
rocketmq-streams-clients/pom.xml | 85 -
.../streams/client/source/DataStreamSource.java | 203 -
.../client/strategy/LogFingerprintStrategy.java | 59 -
.../streams/client/strategy/WindowStrategy.java | 60 -
.../streams/client/transform/DataStream.java | 659 -
.../streams/client/transform/JoinStream.java | 202 -
.../streams/client/transform/OverWindowStream.java | 81 -
.../streams/client/transform/SplitStream.java | 66 -
.../streams/client/transform/WindowStream.java | 307 -
.../client/transform/window/HoppingWindow.java | 33 -
.../client/transform/window/SessionWindow.java | 41 -
.../client/transform/window/TumblingWindow.java | 41 -
.../client/transform/window/WindowInfo.java | 105 -
.../rocketmq/streams/client/ApplicationTest.java | 57 -
.../rocketmq/streams/client/DBDriverTest.java | 57 -
.../apache/rocketmq/streams/client/DBSinkTest.java | 87 -
.../rocketmq/streams/client/DataStreamTest.java | 150 -
.../apache/rocketmq/streams/client/FileTest.java | 61 -
.../apache/rocketmq/streams/client/FilterTest.java | 49 -
.../apache/rocketmq/streams/client/JoinTest.java | 65 -
.../rocketmq/streams/client/MqttSourceExample.java | 80 -
.../rocketmq/streams/client/ORMUtilTest.java | 88 -
.../rocketmq/streams/client/OnewayProducer.java | 46 -
.../org/apache/rocketmq/streams/client/Person.java | 89 -
.../streams/client/RocketMQGroupByTest.java | 58 -
.../rocketmq/streams/client/RocketMQTest.java | 196 -
.../streams/client/ScriptOptimizationTest.java | 33 -
.../apache/rocketmq/streams/client/ScriptTest.java | 36 -
.../apache/rocketmq/streams/client/SinkTest.java | 38 -
.../apache/rocketmq/streams/client/SourceTest.java | 94 -
.../apache/rocketmq/streams/client/UnionTest.java | 59 -
.../apache/rocketmq/streams/client/WindowTest.java | 288 -
.../streams/client/example/CountFromFileTest.java | 54 -
.../client/example/CountSupportEmitTest.java | 69 -
.../rocketmq/streams/client/example/JoinTest.java | 90 -
.../rocketmq/streams/client/example/SplitTest.java | 45 -
.../streams/client/sink/UDFDefinedSQLParser.java | 42 -
.../streams/client/sink/UserDefinedSink.java | 33 -
.../client/sink/UserDefinedSupportShuffleSink.java | 44 -
.../streams/client/source/MqttStreamsTest.java | 49 -
.../client/windows/AbstractWindowFireModeTest.java | 203 -
.../streams/client/windows/AbstractWindowTest.java | 219 -
.../streams/client/windows/MultiSplitTest.java | 88 -
.../client/windows/ShuffleOverWindowTest.java | 54 -
.../streams/client/windows/SingleSplitTest.java | 79 -
.../streams/client/windows/WindowDebugTest.java | 30 -
.../windows/WindowFireResultCompareTest.java | 181 -
.../streams/client/windows/WindowMsgManager.java | 73 -
.../src/test/resources/dim.txt | 6 -
.../src/test/resources/log4j.xml | 36 -
.../src/test/resources/window_msg_10.txt | 10 -
.../src/test/resources/window_msg_100.txt | 100 -
.../src/test/resources/window_msg_1000.txt | 1000 -
.../src/test/resources/window_msg_10000.txt | 10000 ---
.../src/test/resources/window_msg_88121.txt | 88121 -------------------
rocketmq-streams-commons/pom.xml | 134 -
.../common/batchsystem/BatchFinishMessage.java | 49 -
.../streams/common/cache/ByteArrayMemoryTable.java | 131 -
.../streams/common/cache/FileBasedTable.java | 405 -
.../common/cache/HybridByteBufferTable.java | 647 -
.../streams/common/cache/ListMemoryTable.java | 83 -
.../common/cache/MappedByteBufferTable.java | 602 -
.../rocketmq/streams/common/cache/TableSchema.java | 64 -
.../common/cache/compress/AbstractMemoryTable.java | 358 -
.../common/cache/compress/AdditionStore.java | 225 -
.../common/cache/compress/BigMapAddress.java | 96 -
.../streams/common/cache/compress/BitSetCache.java | 162 -
.../streams/common/cache/compress/ByteArray.java | 117 -
.../common/cache/compress/ByteArrayValueKV.java | 102 -
.../streams/common/cache/compress/ByteStore.java | 226 -
.../streams/common/cache/compress/CacheKV.java | 281 -
.../streams/common/cache/compress/ICacheKV.java | 62 -
.../streams/common/cache/compress/KVAddress.java | 149 -
.../streams/common/cache/compress/KVElement.java | 127 -
.../cache/compress/MappedByteBufferStore.java | 191 -
.../common/cache/compress/impl/AbstractListKV.java | 159 -
.../cache/compress/impl/FixedLenRowCacheKV.java | 156 -
.../common/cache/compress/impl/IntValueKV.java | 72 -
.../streams/common/cache/compress/impl/KeySet.java | 81 -
.../common/cache/compress/impl/LongListKV.java | 102 -
.../common/cache/compress/impl/LongValueKV.java | 67 -
.../cache/compress/impl/MapAddressListKV.java | 156 -
.../common/cache/compress/impl/MultiValueKV.java | 113 -
.../common/cache/compress/impl/MutilValueKV.java | 114 -
.../common/cache/compress/impl/SplitCache.java | 87 -
.../common/cache/compress/impl/StringValueKV.java | 75 -
.../streams/common/cache/softreference/ICache.java | 58 -
.../softreference/impl/SoftReferenceCache.java | 126 -
.../streams/common/calssscaner/AbstractScan.java | 288 -
.../streams/common/channel/AbstractChannel.java | 265 -
.../rocketmq/streams/common/channel/IChannel.java | 33 -
.../AbstractChannelSQLSupportShuffleSQLParser.java | 44 -
.../AbstractSupportShuffleChannelBuilder.java | 43 -
.../common/channel/builder/IChannelBuilder.java | 69 -
.../channel/builder/IShuffleChannelBuilder.java | 39 -
.../common/channel/impl/CollectionSink.java | 55 -
.../common/channel/impl/CollectionSinkBuilder.java | 50 -
.../common/channel/impl/CollectionSource.java | 161 -
.../channel/impl/CollectionSourceBuilder.java | 54 -
.../common/channel/impl/OutputPrintChannel.java | 40 -
.../common/channel/impl/PrintChannelBuilder.java | 46 -
.../channel/impl/file/FileChannelBuilder.java | 94 -
.../streams/common/channel/impl/file/FileSink.java | 170 -
.../common/channel/impl/file/FileSource.java | 246 -
.../common/channel/impl/file/FileSplit.java | 57 -
.../common/channel/impl/memory/MemoryCache.java | 79 -
.../common/channel/impl/memory/MemoryChannel.java | 83 -
.../channel/impl/memory/MemoryChannelBuilder.java | 64 -
.../common/channel/impl/memory/MemorySink.java | 106 -
.../common/channel/impl/memory/MemorySource.java | 95 -
.../channel/impl/view/ViewChannelBuilder.java | 68 -
.../streams/common/channel/impl/view/ViewSink.java | 41 -
.../common/channel/impl/view/ViewSource.java | 66 -
.../streams/common/channel/sink/AbstractSink.java | 296 -
.../channel/sink/AbstractSupportShuffleSink.java | 84 -
.../sink/AbstractSupportShuffleUDFSink.java | 50 -
.../common/channel/sink/AbstractUDFSink.java | 75 -
.../streams/common/channel/sink/ISink.java | 123 -
.../channel/sinkcache/DataSourceAutoFlushTask.java | 83 -
.../common/channel/sinkcache/IMessageCache.java | 77 -
.../channel/sinkcache/IMessageFlushCallBack.java | 29 -
.../impl/AbstractMultiSplitMessageCache.java | 202 -
.../channel/sinkcache/impl/MessageCache.java | 176 -
.../sinkcache/impl/MultiSplitMessageCache.java | 33 -
.../common/channel/source/AbstractBatchSource.java | 209 -
.../common/channel/source/AbstractSource.java | 768 -
.../channel/source/AbstractUnreliableSource.java | 163 -
.../streams/common/channel/source/ISource.java | 98 -
.../channel/source/ISplitChangedListener.java | 40 -
.../source/systemmsg/ChangeTableNameMessage.java | 43 -
.../channel/source/systemmsg/NewSplitMessage.java | 26 -
.../source/systemmsg/RemoveSplitMessage.java | 26 -
.../source/systemmsg/SplitChangedMessage.java | 72 -
.../streams/common/channel/split/ISplit.java | 39 -
.../checkpoint/AbstractCheckPointStorage.java | 198 -
.../streams/common/checkpoint/CheckPoint.java | 129 -
.../common/checkpoint/CheckPointManager.java | 211 -
.../common/checkpoint/CheckPointMessage.java | 81 -
.../streams/common/checkpoint/CheckPointState.java | 62 -
.../checkpoint/CheckPointStorageFactory.java | 73 -
.../streams/common/checkpoint/ICheckPoint.java | 31 -
.../common/checkpoint/ICheckPointStorage.java | 41 -
.../streams/common/checkpoint/SourceSnapShot.java | 75 -
.../streams/common/checkpoint/SourceState.java | 56 -
.../common/classloader/ByteClassLoader.java | 30 -
.../common/classloader/FileClassLoader.java | 81 -
.../common/classloader/IsolationClassLoader.java | 78 -
.../common/compiler/CustomJavaCompiler.java | 257 -
.../common/component/AbstractComponent.java | 208 -
.../streams/common/component/ComponentCreator.java | 269 -
.../common/component/ConfigureDescriptor.java | 98 -
.../streams/common/component/IComponent.java | 73 -
.../PropertyConfigureDescriptorManager.java | 108 -
.../PropertyConfigureDiscriptorManager.java | 114 -
.../common/configurable/AbstractConfigurable.java | 203 -
.../common/configurable/BasedConfigurable.java | 261 -
.../IAfterConfigurableRefreshListener.java | 25 -
.../streams/common/configurable/IConfigurable.java | 83 -
.../configurable/IConfigurableIdentification.java | 40 -
.../common/configurable/IConfigurableService.java | 139 -
.../common/configurable/IFieldProcessor.java | 24 -
.../common/configurable/annotation/Changeable.java | 31 -
.../configurable/annotation/ENVDependence.java | 30 -
.../configurable/annotation/NoSerialized.java | 29 -
.../streams/common/configure/ConfigureFileKey.java | 138 -
.../streams/common/configure/StreamsConfigure.java | 59 -
.../streams/common/context/AbstractContext.java | 465 -
.../streams/common/context/BatchMessageOffset.java | 122 -
.../rocketmq/streams/common/context/Context.java | 33 -
.../rocketmq/streams/common/context/IMessage.java | 84 -
.../rocketmq/streams/common/context/Message.java | 135 -
.../streams/common/context/MessageHeader.java | 372 -
.../streams/common/context/MessageOffset.java | 185 -
.../streams/common/context/UserDefinedMessage.java | 479 -
.../streams/common/datatype/ArrayDataType.java | 281 -
.../streams/common/datatype/BaseDataType.java | 228 -
.../streams/common/datatype/BooleanDataType.java | 141 -
.../streams/common/datatype/ByteDataType.java | 106 -
.../common/datatype/ConfigurableDataType.java | 127 -
.../streams/common/datatype/DataJsonable.java | 36 -
.../rocketmq/streams/common/datatype/DataType.java | 109 -
.../streams/common/datatype/DateDataType.java | 169 -
.../streams/common/datatype/DateTimeDataType.java | 43 -
.../streams/common/datatype/DoubleDataType.java | 155 -
.../streams/common/datatype/FloatDataType.java | 140 -
.../common/datatype/GenericParameterDataType.java | 165 -
.../common/datatype/GenericParamterDataType.java | 123 -
.../streams/common/datatype/HllDataType.java | 79 -
.../streams/common/datatype/IJsonable.java | 34 -
.../streams/common/datatype/IntDataType.java | 122 -
.../streams/common/datatype/JavaBeanDataType.java | 345 -
.../streams/common/datatype/JsonableDataType.java | 104 -
.../streams/common/datatype/ListDataType.java | 287 -
.../streams/common/datatype/LongDataType.java | 175 -
.../streams/common/datatype/MapDataType.java | 362 -
.../common/datatype/NotSupportDataType.java | 74 -
.../streams/common/datatype/NumberDataType.java | 83 -
.../common/datatype/SerializableDataType.java | 86 -
.../streams/common/datatype/SetDataType.java | 278 -
.../streams/common/datatype/ShortDataType.java | 117 -
.../streams/common/datatype/StringDataType.java | 83 -
.../streams/common/dboperator/IDBDriver.java | 79 -
.../common/disruptor/DisruptorEventFactory.java | 26 -
.../common/disruptor/DisruptorProducer.java | 51 -
.../streams/common/functions/FilterFunction.java | 23 -
.../streams/common/functions/ForEachFunction.java | 29 -
.../common/functions/ForEachMessageFunction.java | 29 -
.../streams/common/functions/Function.java | 19 -
.../streams/common/functions/MapFunction.java | 24 -
.../common/functions/MultiTableSplitFunction.java | 27 -
.../streams/common/functions/ReduceFunction.java | 22 -
.../streams/common/functions/SplitFunction.java | 30 -
.../common/functions/TableSplitFunction.java | 46 -
.../common/interfaces/IBaseStreamOperator.java | 33 -
.../interfaces/IBatchMessageFinishNotify.java | 32 -
.../streams/common/interfaces/IFilterService.java | 66 -
.../streams/common/interfaces/IJDBCOperator.java | 77 -
.../common/interfaces/IJsonobjectProcessor.java | 25 -
.../streams/common/interfaces/ILifeCycle.java | 27 -
.../common/interfaces/ILineMessageProcessor.java | 32 -
.../streams/common/interfaces/IPropertyEnable.java | 38 -
.../common/interfaces/IScheduleExecutor.java | 27 -
.../streams/common/interfaces/IStreamOperator.java | 29 -
.../common/interfaces/ISystemMessageProcessor.java | 23 -
.../streams/common/logger/LoggerCreator.java | 57 -
.../streams/common/logger/LoggerOutputChannel.java | 78 -
.../common/logger/MyDailyRollingFileAppender.java | 554 -
.../streams/common/metadata/AbstractMetaData.java | 250 -
.../streams/common/metadata/LogicMetaData.java | 57 -
.../rocketmq/streams/common/metadata/MetaData.java | 226 -
.../streams/common/metadata/MetaDataAdapter.java | 47 -
.../streams/common/metadata/MetaDataField.java | 171 -
.../streams/common/metadata/MetaDataUtils.java | 249 -
.../rocketmq/streams/common/model/Entity.java | 49 -
.../rocketmq/streams/common/model/NameCreator.java | 60 -
.../streams/common/model/NameCreatorContext.java | 44 -
.../rocketmq/streams/common/model/ServiceName.java | 36 -
.../streams/common/model/ThreadContext.java | 31 -
.../common/monitor/ConsoleMonitorManager.java | 412 -
.../streams/common/monitor/DataSyncConstants.java | 54 -
.../streams/common/monitor/HttpClient.java | 116 -
.../rocketmq/streams/common/monitor/HttpUtil.java | 248 -
.../rocketmq/streams/common/monitor/IMonitor.java | 170 -
.../monitor/MonitorDataSyncServiceFactory.java | 61 -
.../streams/common/monitor/MonitorFactory.java | 132 -
.../common/monitor/TopologyFilterMonitor.java | 70 -
.../common/monitor/group/GroupedMonitorInfo.java | 119 -
.../common/monitor/group/MonitorCommander.java | 203 -
.../streams/common/monitor/impl/DipperMonitor.java | 512 -
.../streams/common/monitor/impl/MonitorItem.java | 176 -
.../common/monitor/impl/NothingMonitorItem.java | 62 -
.../common/monitor/impl/NothingMontior.java | 111 -
.../streams/common/monitor/model/JobStage.java | 350 -
.../streams/common/monitor/model/TraceIdsDO.java | 126 -
.../common/monitor/model/TraceMonitorDO.java | 250 -
.../monitor/service/MonitorDataSyncService.java | 32 -
.../service/impl/DBMonitorDataSyncImpl.java | 63 -
.../service/impl/HttpMonitorDataSyncImpl.java | 151 -
.../service/impl/RocketMQMonitorDataSyncImpl.java | 185 -
.../common/optimization/FilterResultCache.java | 52 -
.../streams/common/optimization/HomologousVar.java | 52 -
.../common/optimization/HyperscanEngine.java | 161 -
.../optimization/IHomologousOptimization.java | 30 -
.../streams/common/optimization/IStreamRegex.java | 65 -
.../streams/common/optimization/LikeRegex.java | 234 -
.../common/optimization/MessageGlobleTrace.java | 79 -
.../common/optimization/OptimizationRegex.java | 295 -
.../streams/common/optimization/Re2Engine.java | 142 -
.../streams/common/optimization/RegexEngine.java | 73 -
.../common/optimization/TaskOptimization.java | 71 -
.../optimization/fingerprint/FingerprintCache.java | 218 -
.../fingerprint/FingerprintMetric.java | 97 -
.../optimization/fingerprint/PreFingerprint.java | 151 -
.../common/schedule/IScheduleCondition.java | 22 -
.../streams/common/schedule/ScheduleManager.java | 74 -
.../streams/common/schedule/ScheduleTask.java | 101 -
.../common/threadpool/ThreadPoolFactory.java | 69 -
.../AbstractMutilPipelineChainPipline.java | 225 -
.../streams/common/topology/ChainPipeline.java | 595 -
.../streams/common/topology/ChainStage.java | 113 -
.../streams/common/topology/SectionPipeline.java | 106 -
.../common/topology/builder/IStageBuilder.java | 39 -
.../common/topology/builder/PipelineBuilder.java | 472 -
.../common/topology/metric/NotFireReason.java | 176 -
.../streams/common/topology/metric/StageGroup.java | 248 -
.../common/topology/metric/StageMetric.java | 138 -
.../common/topology/model/AbstractRule.java | 191 -
.../common/topology/model/AbstractScript.java | 109 -
.../common/topology/model/AbstractStage.java | 374 -
.../streams/common/topology/model/IWindow.java | 112 -
.../streams/common/topology/model/Pipeline.java | 345 -
.../streams/common/topology/model/Union.java | 63 -
.../topology/shuffle/IShuffleKeyGenerator.java | 24 -
.../common/topology/shuffle/ShuffleMQCreator.java | 406 -
.../stages/AbstractStatelessChainStage.java | 41 -
.../topology/stages/AbstractWindowStage.java | 98 -
.../common/topology/stages/EmptyChainStage.java | 45 -
.../common/topology/stages/FilterChainStage.java | 233 -
.../common/topology/stages/JoinChainStage.java | 165 -
.../common/topology/stages/JoinEndChainStage.java | 20 -
.../topology/stages/JoinStartChainStage.java | 67 -
.../common/topology/stages/NewSQLChainStage.java | 82 -
.../common/topology/stages/OpenAPIChainStage.java | 79 -
.../common/topology/stages/OutputChainStage.java | 251 -
.../common/topology/stages/PythonChainStage.java | 79 -
.../topology/stages/RightJoinChainStage.java | 92 -
.../common/topology/stages/SQLChainStage.java | 80 -
.../common/topology/stages/ScriptChainStage.java | 122 -
.../topology/stages/ShuffleConsumerChainStage.java | 193 -
.../topology/stages/ShuffleProducerChainStage.java | 345 -
.../common/topology/stages/UnionChainStage.java | 51 -
.../common/topology/stages/UnionEndChainStage.java | 20 -
.../topology/stages/UnionStartChainStage.java | 59 -
.../common/topology/stages/ViewChainStage.java | 529 -
.../common/topology/stages/WindowChainStage.java | 83 -
.../common/topology/stages/udf/IReducer.java | 34 -
.../common/topology/stages/udf/MapOperator.java | 37 -
.../common/topology/stages/udf/StageBuilder.java | 87 -
.../common/topology/stages/udf/UDFChainStage.java | 84 -
.../topology/stages/udf/UDFUnionChainStage.java | 90 -
.../streams/common/topology/task/StreamsTask.java | 160 -
.../streams/common/topology/task/TaskAssigner.java | 48 -
.../streams/common/transport/IFileTransport.java | 68 -
.../rocketmq/streams/common/utils/AESUtil.java | 119 -
.../rocketmq/streams/common/utils/Base64Utils.java | 104 -
.../rocketmq/streams/common/utils/ClassUtil.java | 156 -
.../streams/common/utils/CollectionUtil.java | 65 -
.../rocketmq/streams/common/utils/CommandUtil.java | 183 -
.../streams/common/utils/CompressUtil.java | 153 -
.../streams/common/utils/ConfigurableUtil.java | 215 -
.../streams/common/utils/ContantsUtil.java | 369 -
.../streams/common/utils/CreateTopicUtil.java | 57 -
.../rocketmq/streams/common/utils/DESUtils.java | 147 -
.../streams/common/utils/DataTypeUtil.java | 602 -
.../rocketmq/streams/common/utils/DateUtil.java | 608 -
.../common/utils/DipperThreadLocalUtil.java | 35 -
.../rocketmq/streams/common/utils/ENVUtile.java | 55 -
.../rocketmq/streams/common/utils/FileUtil.java | 1048 -
.../rocketmq/streams/common/utils/IOUtil.java | 104 -
.../rocketmq/streams/common/utils/IPUtil.java | 200 -
.../streams/common/utils/InstantiationUtil.java | 122 -
.../streams/common/utils/Ip2LongUtils.java | 296 -
.../rocketmq/streams/common/utils/JarUtil.java | 156 -
.../streams/common/utils/JsonableUtil.java | 65 -
.../rocketmq/streams/common/utils/KryoUtil.java | 210 -
.../streams/common/utils/LogParserUtil.java | 241 -
.../rocketmq/streams/common/utils/MapKeyUtil.java | 172 -
.../rocketmq/streams/common/utils/MessageUtil.java | 100 -
.../rocketmq/streams/common/utils/NumberUtils.java | 393 -
.../streams/common/utils/PipelineHTMLUtil.java | 299 -
.../rocketmq/streams/common/utils/PrintUtil.java | 212 -
.../streams/common/utils/PropertiesUtils.java | 148 -
.../streams/common/utils/RandomStrUtil.java | 38 -
.../rocketmq/streams/common/utils/ReflectUtil.java | 952 -
.../rocketmq/streams/common/utils/RuntimeUtil.java | 63 -
.../streams/common/utils/SQLFormatterUtil.java | 357 -
.../rocketmq/streams/common/utils/SQLUtil.java | 617 -
.../streams/common/utils/ScheduleUtil.java | 52 -
.../streams/common/utils/SerializeUtil.java | 135 -
.../streams/common/utils/ServiceLoadUtil.java | 63 -
.../rocketmq/streams/common/utils/ShellUtil.java | 180 -
.../rocketmq/streams/common/utils/StringUtil.java | 373 -
.../streams/common/utils/SyslogParserUtil.java | 25 -
.../rocketmq/streams/common/utils/ThreadUtil.java | 29 -
.../rocketmq/streams/common/utils/TraceUtil.java | 113 -
.../rocketmq/streams/common/MessasgeCacheTest.java | 53 -
.../streams/common/cache/compress/BaseTest.java | 149 -
.../cache/compress/HybridByteBufferTableTest.java | 64 -
.../common/cache/compress/IntValueKVTest.java | 66 -
.../cache/compress/MappedByteBufferTest.java | 258 -
.../common/cache/compress/NumberUtilsTest.java | 89 -
.../softreference/SoftReferenceCacheTest.java | 53 -
.../rocketmq/streams/common/channel/SinkTest.java | 72 -
.../streams/common/channel/SourceTest.java | 74 -
.../streams/common/classscan/ClassScanTest.java | 34 -
.../common/compiler/CustomJavaCompilerTest.java | 35 -
.../streams/common/datatype/DataTypeTest.java | 38 -
.../rocketmq/streams/common/regex/RegexTest.java | 65 -
.../streams/common/serializa/CountAccum.java | 46 -
.../rocketmq/streams/common/serializa/Person.java | 113 -
.../streams/common/serializa/SerializeTest.java | 138 -
.../streams/common/stages/SelfChainStageTest.java | 36 -
.../src/test/resources/log4j.xml | 31 -
rocketmq-streams-configurable/pom.xml | 42 -
.../configurable/ConfigurableComponent.java | 184 -
.../streams/configurable/model/Configure.java | 126 -
.../service/AbstractConfigurableService.java | 511 -
.../AbstractSupportParentConfigureService.java | 198 -
.../service/ConfigurableServcieType.java | 29 -
.../service/ConfigurableServiceFactory.java | 56 -
.../service/impl/FileConfigureService.java | 266 -
.../impl/FileSupportParentConfigureService.java | 36 -
.../service/impl/HttpConfigureService.java | 377 -
.../impl/HttpSupportParentConfigureService.java | 44 -
.../service/impl/MemoryConfigureService.java | 120 -
.../impl/MemorySupportParentConfigureService.java | 36 -
.../configuable/ConfiguableComponentTest.java | 112 -
.../rocketmq/streams/configuable/model/Person.java | 109 -
.../src/test/resources/log4j.xml | 36 -
rocketmq-streams-db-operator/pom.xml | 55 -
.../streams/db/configuable/DBConfigureService.java | 286 -
.../DBSupportParentConfigureService.java | 36 -
.../rocketmq/streams/db/driver/DriverBuilder.java | 110 -
.../rocketmq/streams/db/driver/IDriverBudiler.java | 36 -
.../rocketmq/streams/db/driver/JDBCDriver.java | 320 -
.../db/driver/batchloader/BatchRowLoader.java | 177 -
.../db/driver/batchloader/IRowOperator.java | 33 -
.../rocketmq/streams/db/driver/orm/ORMUtil.java | 544 -
.../rocketmq/streams/db/operator/SQLOperator.java | 177 -
.../org/apache/rocketmq/streams/db/Person.java | 109 -
.../DBSupportParentConfigureServiceTest.java | 74 -
.../streams/db/driver/orm/ORMUtilTest.java | 85 -
.../src/main/resources/tables_mysql_innodb.sql | 0
rocketmq-streams-examples/README.md | 228 -
rocketmq-streams-examples/pom.xml | 84 -
.../streams/examples/aggregate/Constant.java | 27 -
.../examples/aggregate/PageDimensionExample.java | 81 -
.../examples/aggregate/RocketMQWindowExample.java | 82 -
.../examples/aggregate/UsersDimensionExample.java | 66 -
.../streams/examples/join/RocketmqJoinExample.java | 36 -
.../mutilconsumer/MultiStreamsExample.java | 93 -
.../schema/CustomeDeserializerExample.java | 65 -
.../streams/examples/schema/DataDeserializer.java | 31 -
.../examples/schema/SchemaRocketmqExample.java | 71 -
.../schema/SchemaRocketmqWindowExample.java | 65 -
.../streams/examples/schema/WordCountExample.java | 61 -
.../streams/examples/send/ProducerFromFile.java | 126 -
.../examples/send/SendMessageContinuously.java | 26 -
.../streams/examples/send/SendMessageOnce.java | 26 -
.../streams/examples/sink/MqttSinkExample.java | 32 -
.../rocketmq/streams/examples/source/Data.java | 74 -
.../streams/examples/source/FileSourceExample.java | 40 -
.../examples/source/RocketmqSourceExample1.java | 56 -
.../examples/source/RocketmqSourceExample2.java | 70 -
.../examples/source/RocketmqSourceExample3.java | 81 -
.../examples/source/RocketmqSourceExample4.java | 64 -
.../src/main/resources/data-2.txt | 10 -
.../src/main/resources/data.txt | 11 -
.../src/main/resources/joinData-1.txt | 4 -
.../src/main/resources/joinData-2.txt | 4 -
.../src/main/resources/pageClickData.txt | 11 -
.../src/main/resources/scores.txt | 18 -
.../src/main/resources/word.txt | 15 -
rocketmq-streams-filter/pom.xml | 43 -
.../rocketmq/streams/filter/FilterComponent.java | 111 -
.../streams/filter/builder/ExpressionBuilder.java | 433 -
.../streams/filter/builder/RuleBuilder.java | 551 -
.../streams/filter/builder/RuleElementBuilder.java | 125 -
.../streams/filter/contants/RuleElementType.java | 42 -
.../streams/filter/context/ContextConfigure.java | 272 -
.../streams/filter/context/RuleContext.java | 394 -
.../streams/filter/context/RuleMessage.java | 48 -
.../streams/filter/engine/IRuleEngine.java | 50 -
.../rocketmq/streams/filter/engine/SplitFlow.java | 158 -
.../filter/engine/impl/DefaultRuleEngine.java | 172 -
.../filter/exception/RegexTimeoutException.java | 48 -
.../filter/function/etl/RenameFunction.java | 37 -
.../expression/AbstractExpressionFunction.java | 46 -
.../function/expression/CompareFunction.java | 87 -
.../ContainsCaseInsensitiveFunction.java | 73 -
.../function/expression/ContainsFunction.java | 62 -
.../streams/filter/function/expression/Equals.java | 165 -
.../function/expression/ExpressionFunction.java | 30 -
.../filter/function/expression/GreaterEquals.java | 162 -
.../filter/function/expression/GreaterThan.java | 131 -
.../filter/function/expression/InFunction.java | 85 -
.../filter/function/expression/InMetaData.java | 65 -
.../function/expression/IpContainsFunction.java | 180 -
.../filter/function/expression/IsNotNull.java | 54 -
.../streams/filter/function/expression/IsNull.java | 51 -
.../filter/function/expression/LessEquals.java | 117 -
.../filter/function/expression/LessThan.java | 119 -
.../filter/function/expression/LikeFunction.java | 164 -
.../NotContainsCaseInsensitiveFunction.java | 75 -
.../function/expression/NotContainsFunction.java | 63 -
.../filter/function/expression/NotEquals.java | 168 -
.../filter/function/expression/NotInFunction.java | 35 -
.../function/expression/NotLikeFunction.java | 36 -
.../NotRegexCaseInsensitiveFunction.java | 36 -
.../function/expression/NotRegexFunction.java | 36 -
.../expression/RegexCaseInsensitiveFunction.java | 41 -
.../filter/function/expression/RegexFunction.java | 112 -
.../filter/function/expression/ScriptFunction.java | 123 -
.../function/script/CaseDependentParser.java | 46 -
.../filter/function/script/CaseFunction.java | 72 -
.../rocketmq/streams/filter/monitor/Monitor.java | 159 -
.../streams/filter/monitor/rule/ActionMonitor.java | 27 -
.../filter/monitor/rule/ExpressionMonitor.java | 27 -
.../filter/monitor/rule/MessageMonitor.java | 118 -
.../streams/filter/monitor/rule/RuleMonitor.java | 64 -
.../streams/filter/monitor/rule/VarMonitor.java | 27 -
.../streams/filter/operator/FilterOperator.java | 33 -
.../rocketmq/streams/filter/operator/Rule.java | 619 -
.../streams/filter/operator/RuleExpression.java | 69 -
.../streams/filter/operator/action/Action.java | 51 -
.../operator/action/IConfigurableAction.java | 25 -
.../filter/operator/action/impl/SinkAction.java | 64 -
.../filter/operator/expression/Expression.java | 481 -
.../operator/expression/ExpressionPerformance.java | 97 -
.../expression/ExpressionRelationParser.java | 104 -
.../operator/expression/GroupExpression.java | 198 -
.../expression/GroupExpressionManager.java | 94 -
.../operator/expression/OptimizationRule.java | 27 -
.../operator/expression/RelationExpression.java | 365 -
.../operator/expression/SimpleExpression.java | 55 -
.../streams/filter/operator/var/ConstantVar.java | 111 -
.../streams/filter/operator/var/ContextVar.java | 86 -
.../streams/filter/operator/var/InnerVar.java | 42 -
.../rocketmq/streams/filter/operator/var/Var.java | 54 -
.../optimization/ExpressionOptimization.java | 143 -
.../PiplineLogFingerprintAnalysis.java | 431 -
.../casewhen/AbstractWhenExpression.java | 216 -
.../optimization/casewhen/CaseWhenBuilder.java | 241 -
.../optimization/casewhen/CaseWhenElement.java | 183 -
.../optimization/casewhen/GroupByVarCaseWhen.java | 122 -
.../casewhen/MutilCaseWhenExpression.java | 45 -
.../casewhen/SingleCaseWhenExpression.java | 98 -
.../filter/optimization/dependency/BlinkRule.java | 122 -
.../dependency/BlinkRuleV2Expression.java | 265 -
.../optimization/dependency/CommonExpression.java | 210 -
.../optimization/dependency/DependencyTree.java | 233 -
.../optimization/dependency/FilterTreeNode.java | 168 -
.../optimization/dependency/PipelineTree.java | 57 -
.../optimization/dependency/ScriptDependent.java | 186 -
.../optimization/dependency/ScriptTreeNode.java | 117 -
.../dependency/SimplePipelineTree.java | 64 -
.../dependency/StateLessDependencyTree.java | 84 -
.../filter/optimization/dependency/TreeNode.java | 184 -
.../optimization/executor/AbstractExecutor.java | 26 -
.../optimization/executor/GroupByVarExecutor.java | 223 -
.../optimization/executor/HyperscanExecutor.java | 142 -
.../optimization/homologous/HomologousCompute.java | 319 -
.../homologous/HomologousOptimization.java | 83 -
.../result/GroupQuickFilterResult.java | 70 -
.../optimization/script/ScriptOptimization.java | 164 -
.../streams/filter/service/IRuleEngineService.java | 39 -
.../filter/service/impl/RuleEngineServiceImpl.java | 96 -
.../rocketmq/streams/filter/utils/IPUtil.java | 208 -
.../rocketmq/streams/filter/utils/RegexUtil.java | 195 -
.../streams/filter/FilterComponentTest.java | 36 -
.../streams/filter/operator/ExpressionTest.java | 47 -
.../src/test/resources/log4j.xml | 36 -
rocketmq-streams-script/pom.xml | 58 -
.../rocketmq/streams/script/ScriptComponent.java | 75 -
.../streams/script/annotation/Function.java | 31 -
.../streams/script/annotation/FunctionMethod.java | 51 -
.../script/annotation/FunctionMethodAilas.java | 37 -
.../script/annotation/FunctionParamter.java | 44 -
.../streams/script/annotation/UDAFFunction.java | 34 -
.../streams/script/context/FunctionContext.java | 76 -
.../function/aggregation/AverageAccumulator.java | 103 -
.../function/aggregation/ConcatAccumulator.java | 95 -
.../aggregation/ConcatDistinctAccumulator.java | 97 -
.../function/aggregation/CountAccumulator.java | 96 -
.../aggregation/CountDistinctAccumulator.java | 72 -
.../function/aggregation/DistinctAccumulator.java | 79 -
.../function/aggregation/DistinctAccumulator2.java | 102 -
.../aggregation/FirstValueAccumulator.java | 74 -
.../function/aggregation/LastValueAccumulator.java | 67 -
.../function/aggregation/MaxAccumulator.java | 110 -
.../function/aggregation/MinAccumulator.java | 113 -
.../script/function/aggregation/SumAccum.java | 47 -
.../function/aggregation/SumAccumulator.java | 81 -
.../function/impl/between/BetweenFunction.java | 76 -
.../script/function/impl/bool/BooleanFunction.java | 39 -
.../script/function/impl/common/EchoFunction.java | 47 -
.../function/impl/condition/EqualsFunction.java | 155 -
.../impl/condition/ExecuteByConditionFuction.java | 36 -
.../impl/condition/GreateEqualsFunction.java | 82 -
.../function/impl/condition/GreaterFunction.java | 69 -
.../script/function/impl/condition/IFFunction.java | 39 -
.../function/impl/condition/IFScopeFunction.java | 36 -
.../impl/condition/InConditionFunction.java | 99 -
.../impl/condition/LessEqualsFunction.java | 71 -
.../function/impl/condition/LessFunction.java | 69 -
.../function/impl/context/ContextFunction.java | 40 -
.../function/impl/date/AddMonthFunction.java | 72 -
.../impl/date/CurrentTimestampFunction.java | 122 -
.../script/function/impl/date/DateAddFunction.java | 143 -
.../function/impl/date/DateDiffFunction.java | 123 -
.../function/impl/date/DateFormatFunction.java | 106 -
.../function/impl/date/DatePartFunction.java | 215 -
.../function/impl/date/DateToCharFunction.java | 92 -
.../function/impl/date/DateTruncFunction.java | 139 -
.../function/impl/date/DateUtilFunction.java | 129 -
.../function/impl/date/DateUtileFunction.java | 151 -
.../script/function/impl/date/DayFunction.java | 61 -
.../function/impl/date/FromUnixTimeFunction.java | 69 -
.../script/function/impl/date/GetDateFunction.java | 39 -
.../script/function/impl/date/IsDateFunction.java | 54 -
.../script/function/impl/date/LastDayFunction.java | 66 -
.../script/function/impl/date/NextDayFunction.java | 97 -
.../script/function/impl/date/NowFuntion.java | 45 -
.../script/function/impl/date/QuarterFuction.java | 75 -
.../script/function/impl/date/QuarterFunction.java | 73 -
.../function/impl/date/UnixTimeStampFunction.java | 74 -
.../function/impl/date/WeekOfYearFunction.java | 58 -
.../script/function/impl/date/WeekdayFunction.java | 57 -
.../function/impl/distinct/DistinctFunction.java | 74 -
.../script/function/impl/env/ENVFunction.java | 47 -
.../script/function/impl/eval/EvalFunction.java | 89 -
.../impl/field/AdditionalFiledFunction.java | 317 -
.../function/impl/field/CoalesceFunction.java | 50 -
.../function/impl/field/ExtraFieldFunction.java | 67 -
.../script/function/impl/field/FieldFunction.java | 174 -
.../function/impl/field/RemoveFieldFunction.java | 70 -
.../function/impl/field/RetainFieldFunction.java | 50 -
.../script/function/impl/filter/BreakFunction.java | 40 -
.../function/impl/filter/FilterFunction.java | 74 -
.../function/impl/flatmap/SplitArrayFunction.java | 171 -
.../impl/flatmap/SplitJsonArrayFunction.java | 49 -
.../function/impl/header/HeaderFunction.java | 46 -
.../script/function/impl/item/ItemFunction.java | 49 -
.../function/impl/json/JsonArrayFunction.java | 229 -
.../function/impl/json/JsonCreatorFunction.java | 218 -
.../function/impl/json/JsonValueFunction.java | 108 -
.../function/impl/json/UDTFFieldNameFunction.java | 50 -
.../script/function/impl/math/AbsFunction.java | 115 -
.../script/function/impl/math/AcosFunction.java | 106 -
.../function/impl/math/AdditionFunction.java | 61 -
.../script/function/impl/math/AsinFunction.java | 106 -
.../script/function/impl/math/AtanFunction.java | 86 -
.../script/function/impl/math/BinFunction.java | 52 -
.../script/function/impl/math/BitFunction.java | 199 -
.../script/function/impl/math/BroundFunction.java | 110 -
.../function/impl/math/CardinalityFunction.java | 47 -
.../script/function/impl/math/CbrtFunction.java | 65 -
.../script/function/impl/math/CeilFunction.java | 106 -
.../script/function/impl/math/ConvFunction.java | 242 -
.../script/function/impl/math/CosFunction.java | 106 -
.../script/function/impl/math/CosHFunction.java | 106 -
.../script/function/impl/math/CotFunction.java | 106 -
.../script/function/impl/math/DegreesFunction.java | 87 -
.../function/impl/math/DivisionFunction.java | 61 -
.../script/function/impl/math/EFunction.java | 40 -
.../script/function/impl/math/ExpFunction.java | 106 -
.../function/impl/math/FactorialFunction.java | 77 -
.../script/function/impl/math/FloorFunction.java | 114 -
.../script/function/impl/math/HexFunction.java | 67 -
.../function/impl/math/IsDecimalFunction.java | 83 -
.../script/function/impl/math/LnFunction.java | 106 -
.../script/function/impl/math/Log10Function.java | 102 -
.../script/function/impl/math/Log2Function.java | 102 -
.../script/function/impl/math/LogFunction.java | 111 -
.../script/function/impl/math/MathFunction.java | 153 -
.../function/impl/math/MultiplicationFunction.java | 62 -
.../function/impl/math/OperationFunction.java | 121 -
.../script/function/impl/math/PIFunction.java | 40 -
.../script/function/impl/math/PowerFunction.java | 111 -
.../script/function/impl/math/RadiansFunction.java | 46 -
.../script/function/impl/math/RandFunction.java | 60 -
.../script/function/impl/math/RoundFunction.java | 114 -
.../function/impl/math/ShiftLeftFunction.java | 50 -
.../function/impl/math/ShiftRightFunction.java | 50 -
.../impl/math/ShiftRightUnSignedFunction.java | 50 -
.../script/function/impl/math/SignFunction.java | 48 -
.../script/function/impl/math/SinFunction.java | 106 -
.../script/function/impl/math/SinHFunction.java | 106 -
.../script/function/impl/math/SqrtFunction.java | 106 -
.../function/impl/math/SubtractionFunction.java | 61 -
.../script/function/impl/math/TanFunction.java | 106 -
.../script/function/impl/math/TanHFunction.java | 106 -
.../script/function/impl/math/TruncFunction.java | 115 -
.../script/function/impl/math/UnHexFunction.java | 62 -
.../script/function/impl/mock/MockFunction.java | 39 -
.../function/impl/offset/OffsetFunction.java | 66 -
.../script/function/impl/parser/GrokFunction.java | 90 -
.../function/impl/parser/LogParserFunction.java | 84 -
.../function/impl/parser/Paser2JsonFunction.java | 171 -
.../function/impl/parser/PaserBySplitFunction.java | 155 -
.../function/impl/parser/RegexParserFunction.java | 74 -
.../function/impl/python/GroovyFunction.java | 50 -
.../function/impl/python/PythonFunction.java | 49 -
.../script/function/impl/relation/AndFunction.java | 65 -
.../script/function/impl/router/RouteFunction.java | 37 -
.../script/function/impl/sql/SQLFunction.java | 56 -
.../script/function/impl/string/AsciiFunction.java | 50 -
.../function/impl/string/Base64Function.java | 85 -
.../function/impl/string/BlinkStringFunction.java | 53 -
.../impl/string/CharMatchCountFunction.java | 58 -
.../script/function/impl/string/ChrFunction.java | 49 -
.../function/impl/string/HashCodeFunction.java | 48 -
.../function/impl/string/InitCapFunction.java | 51 -
.../script/function/impl/string/InstrFunction.java | 134 -
.../function/impl/string/InstrtFunction.java | 134 -
.../function/impl/string/Ip2RegionFunction.java | 41 -
.../function/impl/string/IsEncodingFunction.java | 59 -
.../function/impl/string/KeyValueFunction.java | 117 -
.../script/function/impl/string/LTrimFunction.java | 47 -
.../function/impl/string/LengthBFunction.java | 48 -
.../function/impl/string/LengthFunction.java | 48 -
.../script/function/impl/string/Md5Function.java | 81 -
.../script/function/impl/string/NullFunction.java | 43 -
.../function/impl/string/ParseUrlFunction.java | 99 -
.../script/function/impl/string/RTrimFunction.java | 48 -
.../function/impl/string/RegexCountFunction.java | 110 -
.../script/function/impl/string/RegexFunction.java | 158 -
.../function/impl/string/RegexInstrFunction.java | 177 -
.../function/impl/string/RegexReplaceFunction.java | 90 -
.../function/impl/string/RegexSubStrFunction.java | 124 -
.../function/impl/string/RepeatFunction.java | 58 -
.../function/impl/string/ReplaceFunction.java | 54 -
.../function/impl/string/ReverseFunction.java | 48 -
.../function/impl/string/SoundxFunction.java | 110 -
.../script/function/impl/string/SpaceFunction.java | 58 -
.../function/impl/string/SplitPartFunction.java | 131 -
.../script/function/impl/string/String2Map.java | 49 -
.../impl/string/SubStringIndexFunction.java | 135 -
.../function/impl/string/ToCharFunction.java | 116 -
.../function/impl/string/ToLowerFunction.java | 57 -
.../function/impl/string/ToUpperFunction.java | 47 -
.../function/impl/string/TransLateFunction.java | 55 -
.../script/function/impl/string/TrimFunction.java | 48 -
.../script/function/impl/string/UUIDFunction.java | 39 -
.../function/impl/string/UrlDecodeFunction.java | 82 -
.../function/impl/string/UrlEncodeFunction.java | 122 -
.../script/function/impl/type/CastFunction.java | 72 -
.../script/function/impl/udtf/UDTFFunction.java | 60 -
.../function/impl/window/WindowFunction.java | 64 -
.../script/function/model/FunctionConfigure.java | 571 -
.../function/model/FunctionConfigureMap.java | 111 -
.../script/function/model/FunctionInfo.java | 100 -
.../script/function/model/FunctionInfoMap.java | 84 -
.../function/service/IDipperInterfaceAdpater.java | 46 -
.../script/function/service/IFunctionService.java | 132 -
.../service/impl/DefaultFunctionServiceImpl.java | 427 -
.../function/service/impl/ScanFunctionService.java | 95 -
.../script/operator/AbstractScriptOperator.java | 78 -
.../operator/expression/GroupScriptExpression.java | 340 -
.../operator/expression/ICaseDependentParser.java | 31 -
.../operator/expression/ScriptExpression.java | 401 -
.../operator/expression/ScriptParameter.java | 134 -
.../script/operator/impl/AggregationScript.java | 231 -
.../operator/impl/FileGroovyScriptOperator.java | 33 -
.../operator/impl/FileJPythonScriptOperatore.java | 32 -
.../script/operator/impl/FunctionScript.java | 278 -
.../script/operator/impl/GroovyScriptOperator.java | 105 -
.../operator/impl/JPythonScriptOperator.java | 93 -
.../script/operator/impl/JavaScriptOperator.java | 63 -
.../script/operator/impl/ScriptOperator.java | 29 -
.../optimization/compile/CompileParameter.java | 132 -
.../compile/CompileScriptExpression.java | 119 -
.../performance/IScriptOptimization.java | 75 -
.../script/parser/IScriptExpressionParser.java | 41 -
.../parser/ScriptExpressionParserFactory.java | 69 -
.../parser/imp/ConditionExpressionParser.java | 197 -
.../parser/imp/FunctionExpressionParser.java | 360 -
.../streams/script/parser/imp/FunctionParser.java | 165 -
.../streams/script/service/IAccumulator.java | 67 -
.../script/service/IFunctionFieldDependent.java | 40 -
.../streams/script/service/IScriptExpression.java | 58 -
.../streams/script/service/IScriptParamter.java | 43 -
.../streams/script/service/IScriptService.java | 80 -
.../streams/script/service/IScriptUDFInit.java | 37 -
.../rocketmq/streams/script/service/IUDFScan.java | 26 -
.../script/service/impl/ScriptServiceImpl.java | 119 -
.../script/service/udf/SimpleUDAFScript.java | 37 -
.../streams/script/service/udf/UDAFScript.java | 224 -
.../streams/script/service/udf/UDFScript.java | 307 -
.../streams/script/service/udf/UDTFScript.java | 112 -
.../streams/script/utils/ExpressionUtil.java | 65 -
.../streams/script/utils/FunctionUtils.java | 262 -
.../rocketmq/streams/script/utils/MatchUtil.java | 71 -
.../streams/script/utils/RandomStrUtil.java | 38 -
.../streams/script/utils/ScriptParserUtil.java | 23 -
.../streams/script/utils/StringMatchUtil.java | 87 -
.../rocketmq/streams/script/utils/UniqID.java | 66 -
.../streams/script/function/FunctionTest.java | 105 -
.../streams/script/function/GrokFunctionTest.java | 43 -
.../script/function/GroovyFunctionTest.java | 51 -
.../script/function/JPythonFunctionTest.java | 46 -
.../streams/script/function/UDTFFunctionTest.java | 68 -
.../function/aggregation/AccumulatorTest.java | 234 -
.../function/function/JavaObjectUDFFunction.java | 63 -
.../script/operator/ScriptOperatorTest.java | 103 -
.../streams/script/parser/ScriptParserTest.java | 42 -
.../src/test/resources/log4j.xml | 36 -
rocketmq-streams-serviceloader/pom.xml | 42 -
.../serviceloader/IServiceLoaderService.java | 47 -
.../serviceloader/ServiceLoaderComponent.java | 156 -
.../namefinder/IServiceNameGetter.java | 30 -
.../impl/AnnotationServiceNameGetter.java | 39 -
.../streams/serviceloader/utils/FileUtil.java | 94 -
.../serviceloader/ServiceLoaderComponentTest.java | 33 -
.../src/test/resources/log4j.xml | 36 -
rocketmq-streams-state/pom.xml | 43 -
.../rocketmq/streams/state/AbstractState.java | 116 -
.../rocketmq/streams/state/IEntryProcessor.java | 25 -
.../org/apache/rocketmq/streams/state/ISchama.java | 30 -
.../org/apache/rocketmq/streams/state/IState.java | 239 -
.../apache/rocketmq/streams/state/LruState.java | 264 -
.../streams/state/backend/IStateBackend.java | 151 -
.../rocketmq/streams/state/impl/MapState.java | 25 -
.../apache/rocketmq/streams/state/kv/IKvState.java | 119 -
.../streams/state/kv/rocksdb/RocksDBOperator.java | 129 -
.../streams/state/kv/rocksdb/RocksdbState.java | 264 -
.../rocketmq/streams/state/kv/TestLruState.java | 78 -
.../streams/state/kv/TestRocksdbState.java | 107 -
.../src/test/resources/log4j.xml | 36 -
rocketmq-streams-transport-minio/pom.xml | 40 -
.../transport/minio/MinioFileTransport.java | 140 -
.../streams/configuable/model/DataTpyeTest.java | 32 -
.../rocketmq/streams/configuable/model/Person.java | 97 -
.../streams/configurable/model/Person.java | 96 -
.../src/test/resources/log4j.xml | 36 -
rocketmq-streams-window/pom.xml | 53 -
.../streams/window/builder/WindowBuilder.java | 97 -
.../streams/window/debug/DebugAnalysis.java | 461 -
.../rocketmq/streams/window/debug/DebugWriter.java | 270 -
.../rocketmq/streams/window/debug/WindowDebug.java | 44 -
.../streams/window/fire/EventTimeManager.java | 94 -
.../streams/window/fire/SplitEventTimeManager.java | 106 -
.../window/minibatch/ShuffleMessageCache.java | 185 -
.../rocketmq/streams/window/model/FireMode.java | 61 -
.../streams/window/model/FunctionExecutor.java | 50 -
.../rocketmq/streams/window/model/WindowCache.java | 257 -
.../streams/window/model/WindowInstance.java | 474 -
.../window/operator/AbstractShuffleWindow.java | 153 -
.../streams/window/operator/AbstractWindow.java | 847 -
.../streams/window/operator/impl/OverWindow.java | 172 -
.../window/operator/impl/SessionOperator.java | 489 -
.../window/operator/impl/ShuffleOverWindow.java | 123 -
.../streams/window/operator/impl/TopNState.java | 262 -
.../window/operator/impl/WindowOperator.java | 261 -
.../window/operator/join/ExpressionMatcher.java | 141 -
.../streams/window/operator/join/JoinWindow.java | 625 -
.../window/shuffle/AbstractSystemChannel.java | 331 -
.../streams/window/shuffle/ShuffleCache.java | 163 -
.../streams/window/shuffle/ShuffleChannel.java | 489 -
.../streams/window/source/WindowShuffleSource.java | 87 -
.../streams/window/state/AbstractMapState.java | 47 -
.../streams/window/state/WindowBaseValue.java | 176 -
.../streams/window/state/impl/JoinLeftState.java | 20 -
.../streams/window/state/impl/JoinRightState.java | 20 -
.../streams/window/state/impl/JoinState.java | 93 -
.../streams/window/state/impl/WindowValue.java | 493 -
.../streams/window/storage/AbstractStorage.java | 112 -
.../rocketmq/streams/window/storage/DataType.java | 34 -
.../rocketmq/streams/window/storage/IStorage.java | 78 -
.../streams/window/storage/RocksdbIterator.java | 65 -
.../window/storage/WindowInstanceIterator.java | 39 -
.../streams/window/storage/WindowJoinType.java | 22 -
.../streams/window/storage/WindowType.java | 23 -
.../window/storage/rocketmq/DefaultStorage.java | 390 -
.../window/storage/rocksdb/RocksdbStorage.java | 464 -
.../streams/window/trigger/WindowTrigger.java | 347 -
.../rocketmq/streams/window/util/ShuffleUtil.java | 62 -
.../streams/window/util/WindowChannellUtil.java | 132 -
.../org/apache/rocketmq/streams/RocksdbTest.java | 102 -
.../streams/configruation/model/Person.java | 99 -
.../streams/configurable/model/Person.java | 96 -
.../rocketmq/streams/storage/RocksdbTest.java | 204 -
.../streams/window/WindowInstanceTest.java | 277 -
.../rocketmq/streams/window/WindowValueTest.java | 71 -
.../src/test/resources/log4j.xml | 36 -
1034 files changed, 7229 insertions(+), 212231 deletions(-)
create mode 100644 core/pom.xml
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/RocketMQStream.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/common/Constant.java
copy rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/component/IgnoreNameSpace.java => core/src/main/java/org/apache/rocketmq/streams/core/function/AggregateAction.java (82%)
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/disruptor/BufferFullFunction.java => core/src/main/java/org/apache/rocketmq/streams/core/function/FilterAction.java (81%)
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configurable/IConfigurableListerner.java => core/src/main/java/org/apache/rocketmq/streams/core/function/ForeachAction.java (85%)
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/source/AbstractSupportShuffleSource.java => core/src/main/java/org/apache/rocketmq/streams/core/function/KeySelectAction.java (85%)
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/IExpressionResultCache.java => core/src/main/java/org/apache/rocketmq/streams/core/function/ValueJoinAction.java (84%)
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/component/IgnoreNameSpace.java => core/src/main/java/org/apache/rocketmq/streams/core/function/ValueMapperAction.java (85%)
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AddTagSupplier.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AggregateSupplier.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/FilterSupplier.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ForeachSupplier.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/KeySelectSupplier.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/PrintSupplier.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SinkSupplier.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SourceSupplier.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/TimestampSelectorSupplier.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/metadata/Data.java
rename rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/window/Time.java => core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java (53%)
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/model/BeanHolder.java => core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java (65%)
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/rstream/JoinedStream.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/rstream/Pipeline.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/rstream/RStream.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/rstream/RStreamImpl.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/rstream/StreamBuilder.java
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/builder/AbstractChannelSQLParser.java => core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStream.java (64%)
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractProcessor.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractWindowProcessor.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/interfaces/ITransport.java => core/src/main/java/org/apache/rocketmq/streams/core/running/Processor.java (76%)
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/running/RocketMQClient.java
rename rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/strategy/ShuffleStrategy.java => core/src/main/java/org/apache/rocketmq/streams/core/running/StreamContext.java (55%)
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/running/StreamContextImpl.java
rename rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/contants/RuleStatus.java => core/src/main/java/org/apache/rocketmq/streams/core/running/Task.java (86%)
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/interfaces/ISystemMessage.java => core/src/main/java/org/apache/rocketmq/streams/core/runtime/operators/JoinType.java (87%)
rename rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/UserDefinedSourceTest.java => core/src/main/java/org/apache/rocketmq/streams/core/runtime/operators/StreamType.java (87%)
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/runtime/operators/Time.java
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/interfaces/ISerialize.java => core/src/main/java/org/apache/rocketmq/streams/core/runtime/operators/TimeType.java (87%)
rename rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/monitor/rule/NullMonitor.java => core/src/main/java/org/apache/rocketmq/streams/core/runtime/operators/Window.java (54%)
rename rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/impl/OrderBy.java => core/src/main/java/org/apache/rocketmq/streams/core/runtime/operators/WindowBuilder.java (51%)
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/runtime/operators/WindowInfo.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/runtime/operators/WindowKey.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/runtime/operators/WindowState.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/runtime/operators/WindowStore.java
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/model/IStageHandle.java => core/src/main/java/org/apache/rocketmq/streams/core/serialization/JsonSerDe.java (56%)
rename rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/platform/BlinkUDFFunction.java => core/src/main/java/org/apache/rocketmq/streams/core/serialization/KeyValueDeserializer.java (74%)
rename rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/strategy/Strategy.java => core/src/main/java/org/apache/rocketmq/streams/core/serialization/KeyValueSerializer.java (83%)
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/softreference/RebuildCacheElement.java => core/src/main/java/org/apache/rocketmq/streams/core/serialization/SerDeWrapper.java (77%)
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/serialization/ShuffleProtocol.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/serialization/deImpl/KVAvroDeserializer.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/serialization/deImpl/KVJsonDeserializer.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/serialization/serImpl/KVAvroSerializer.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/serialization/serImpl/KVJsonSerializer.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/state/RocksDBKey.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/state/RocksDBStore.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/state/StateStore.java
rename rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/aggregation/CountAccum.java => core/src/main/java/org/apache/rocketmq/streams/core/topology/Topology.java (77%)
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/topology/TopologyBuilder.java
rename rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/monitor/contants/MonitorType.java => core/src/main/java/org/apache/rocketmq/streams/core/topology/real/ProcessorFactory.java (58%)
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/functions/FlatMapFunction.java => core/src/main/java/org/apache/rocketmq/streams/core/topology/real/RealProcessorFactory.java (79%)
rename rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/schema/StringSchemaWrapper.java => core/src/main/java/org/apache/rocketmq/streams/core/topology/real/SinkFactory.java (55%)
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/transport/AbstractFileTransport.java => core/src/main/java/org/apache/rocketmq/streams/core/topology/real/SourceFactory.java (55%)
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/AbstractGraphNode.java
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/model/ILifeCycle.java => core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/GraphNode.java (67%)
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/ProcessorNode.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/ShuffleProcessorNode.java
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/memory/MemorySplit.java => core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/SinkGraphNode.java (52%)
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/SourceGraphNode.java
rename rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/source/UserDefinedSource.java => core/src/main/java/org/apache/rocketmq/streams/core/util/CommonNameMaker.java (62%)
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/util/OperatorNameMaker.java
rename rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/IteratorWrap.java => core/src/main/java/org/apache/rocketmq/streams/core/util/Pair.java (57%)
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java
create mode 100644 core/src/main/java/org/apache/rocketmq/streams/core/util/Utils.java
create mode 100644 core/src/main/resources/logback.xml
rename rocketmq-streams-script/src/test/java/org/apache/rocketmq/streams/script/function/function/Person.java => core/src/test/java/org/apache/rocketmq/streams/core/Num.java (78%)
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/RegexUtil.java => core/src/test/java/org/apache/rocketmq/streams/core/Test.java (91%)
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/IgnoreMessage.java => core/src/test/java/org/apache/rocketmq/streams/core/User.java (79%)
create mode 100644 core/src/test/java/org/apache/rocketmq/streams/core/function/AggregateSupplier.java
rename rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/StreamBuilder.java => core/src/test/java/org/apache/rocketmq/streams/core/runtime/WindowStateTests.java (53%)
create mode 100644 core/src/test/java/org/apache/rocketmq/streams/core/state/RocksDBStoreTest.java
create mode 100644 core/src/test/java/org/apache/rocketmq/streams/core/util/UtilsTests.java
delete mode 100644 docs/SUMMARY.md
delete mode 100644 "docs/design/1.RocketMQ-streams\346\225\264\344\275\223\346\236\266\346\236\204.md"
delete mode 100644 "docs/design/2.\346\236\204\345\273\272DataStream.md"
delete mode 100644 "docs/design/3.\345\220\257\345\212\250DataStream.md"
delete mode 100644 "docs/design/4.\346\225\260\346\215\256\347\232\204\346\265\201\350\275\254\350\277\207\347\250\213.md"
delete mode 100644 "docs/design/5.Window\347\256\227\345\255\220\350\247\243\346\236\220.md"
delete mode 100644 "docs/images/Pipeline\347\261\273\345\233\276.png"
delete mode 100644 "docs/images/RocketMQ-streams\346\211\251\347\274\251\345\256\271.png"
delete mode 100644 docs/images/window.png
delete mode 100644 "docs/images/\346\200\273\344\275\223\346\236\266\346\236\204\345\233\276.png"
delete mode 100644 "docs/images/\346\200\273\344\275\223\350\277\207\347\250\213.png"
delete mode 100644 "docs/images/\346\211\251\347\274\251\345\256\271.png"
delete mode 100644 "docs/images/\346\234\211\347\212\266\346\200\201\347\256\227\345\255\220.png"
delete mode 100644 "docs/images/\346\266\210\350\264\271\346\250\241\345\236\213.png"
delete mode 100644 "docs/images/\347\212\266\346\200\201\345\255\230\345\202\250.png"
delete mode 100644 docs/stream_sink/README.md
delete mode 100644 docs/stream_source/README.md
delete mode 100644 docs/stream_transform/README.md
rename {rocketmq-streams-channel-mqtt => example}/pom.xml (59%)
create mode 100644 example/src/main/java/org/apache/rocketmq/streams/examples/WordCount.java
create mode 100644 example/src/main/java/org/apache/rocketmq/streams/examples/joinWindow/JoinWindow.java
create mode 100644 example/src/main/java/org/apache/rocketmq/streams/examples/pojo/Demo.java
rename rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/model/FunctionType.java => example/src/main/java/org/apache/rocketmq/streams/examples/pojo/Num.java (58%)
rename rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/CycleSplit.java => example/src/main/java/org/apache/rocketmq/streams/examples/pojo/Union.java (51%)
rename rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/disruptor/DisruptorEvent.java => example/src/main/java/org/apache/rocketmq/streams/examples/pojo/User.java (57%)
create mode 100644 example/src/main/java/org/apache/rocketmq/streams/examples/window/SessionWindowCount.java
create mode 100644 example/src/main/java/org/apache/rocketmq/streams/examples/window/SlideWindowCount.java
create mode 100644 example/src/main/java/org/apache/rocketmq/streams/examples/window/windowCount.java
create mode 100644 example/src/main/java/org/apache/rocketmq/streams/examples/window/windowWordCount.java
delete mode 100755 rocketmq-streams-channel-db/pom.xml
delete mode 100644 rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/DynamicMultipleDBSplit.java
delete mode 100644 rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/AbstractMultiTableSink.java
delete mode 100644 rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/DBSink.java
delete mode 100644 rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/DBSinkBuilder.java
delete mode 100644 rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/DynamicMultipleDBSink.java
delete mode 100644 rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/EnhanceDBSink.java
delete mode 100644 rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/SelfMultiTableSink.java
delete mode 100644 rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/SplitBySerialNumber.java
delete mode 100644 rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/SplitByTimeMultiTableSink.java
delete mode 100644 rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/sqltemplate/ISqlTemplate.java
delete mode 100644 rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/sqltemplate/MysqlInsertIgnoreIntoSqlTemplate.java
delete mode 100644 rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/sqltemplate/MysqlInsertIntoSqlTemplate.java
delete mode 100644 rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/sqltemplate/MysqlInsertIntoWithDuplicateKeySqlTemplate.java
delete mode 100644 rocketmq-streams-channel-db/src/main/java/org/apache/rocketmq/streams/db/sink/sqltemplate/SqlTemplateFactory.java
delete mode 100644 rocketmq-streams-channel-db/src/test/java/org/apache/rocketmq/streams/db/sink/db/DBWriteOnlyChannelTest.java
delete mode 100644 rocketmq-streams-channel-db/src/test/java/org/apache/rocketmq/streams/db/sink/db/ISqlTemplateTest.java
delete mode 100644 rocketmq-streams-channel-es/.gitignore
delete mode 100755 rocketmq-streams-channel-es/pom.xml
delete mode 100644 rocketmq-streams-channel-es/src/main/java/org/apache/rocketmq/streams/es/sink/ESChannelBuilder.java
delete mode 100644 rocketmq-streams-channel-es/src/main/java/org/apache/rocketmq/streams/es/sink/ESSinkBuilder.java
delete mode 100644 rocketmq-streams-channel-es/src/main/java/org/apache/rocketmq/streams/es/sink/ESSinkOnlyChannel.java
delete mode 100644 rocketmq-streams-channel-es/src/main/java/org/apache/rocketmq/streams/es/sink/EsClient.java
delete mode 100644 rocketmq-streams-channel-es/src/test/java/org/apache/rocketmq/streams/db/sink/es/EsChannelTest.java
delete mode 100644 rocketmq-streams-channel-http/pom.xml
delete mode 100644 rocketmq-streams-channel-http/src/main/java/org/apache/rocketmq/streams/http/source/HttpSource.java
delete mode 100644 rocketmq-streams-channel-http/src/main/java/org/apache/rocketmq/streams/http/source/server/HttpServer.java
delete mode 100644 rocketmq-streams-channel-http/src/main/java/org/apache/rocketmq/streams/http/source/server/HttpServerManager.java
delete mode 100644 rocketmq-streams-channel-http/src/main/java/org/apache/rocketmq/streams/http/source/util/HttpUtil.java
delete mode 100644 rocketmq-streams-channel-http/src/test/java/org/apache/rocketmq/streams/http/source/http/HttpChannelTest.java
delete mode 100644 rocketmq-streams-channel-mqtt/src/main/java/org/apache/rocketmq/streams/mqtt/MqttChannelBuilder.java
delete mode 100644 rocketmq-streams-channel-mqtt/src/main/java/org/apache/rocketmq/streams/mqtt/sink/PahoSink.java
delete mode 100644 rocketmq-streams-channel-mqtt/src/main/java/org/apache/rocketmq/streams/mqtt/source/PahoSource.java
delete mode 100644 rocketmq-streams-channel-mqtt/src/test/java/org/apache/rocketmq/streams/mqtt/PahoTest.java
delete mode 100644 rocketmq-streams-channel-rocketmq/pom.xml
delete mode 100644 rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/RocketMQChannelBuilder.java
delete mode 100644 rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/debug/DebugWriter.java
delete mode 100644 rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/queue/RocketMQMessageQueue.java
delete mode 100644 rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/schema/AvroSchemaWrapper.java
delete mode 100644 rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/schema/CustomSchemaWrapper.java
delete mode 100644 rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/schema/JsonSchemaWrapper.java
delete mode 100644 rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/schema/SchemaConfig.java
delete mode 100644 rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/schema/SchemaType.java
delete mode 100644 rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/schema/SchemaWrapper.java
delete mode 100644 rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/schema/SchemaWrapperFactory.java
delete mode 100644 rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/sink/RocketMQSink.java
delete mode 100644 rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/source/MessageListenerDelegator.java
delete mode 100644 rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/source/RocketMQSource.java
delete mode 100644 rocketmq-streams-channel-rocketmq/src/test/java/org/apache/rocketmq/streams/AbstractChannelTest.java
delete mode 100644 rocketmq-streams-channel-rocketmq/src/test/java/org/apache/rocketmq/streams/RocketMQChannelTest.java
delete mode 100644 rocketmq-streams-channel-syslog/.gitignore
delete mode 100755 rocketmq-streams-channel-syslog/pom.xml
delete mode 100644 rocketmq-streams-channel-syslog/src/main/java/org/apache/rocketmq/streams/syslog/ISyslogRouter.java
delete mode 100644 rocketmq-streams-channel-syslog/src/main/java/org/apache/rocketmq/streams/syslog/SyslogChannel.java
delete mode 100644 rocketmq-streams-channel-syslog/src/main/java/org/apache/rocketmq/streams/syslog/SyslogChannelBuilder.java
delete mode 100644 rocketmq-streams-channel-syslog/src/main/java/org/apache/rocketmq/streams/syslog/SyslogChannelManager.java
delete mode 100644 rocketmq-streams-channel-syslog/src/main/java/org/apache/rocketmq/streams/syslog/SyslogParser.java
delete mode 100644 rocketmq-streams-channel-syslog/src/main/java/org/apache/rocketmq/streams/syslog/SyslogServer.java
delete mode 100644 rocketmq-streams-channel-syslog/src/test/java/org/apache/rocketmq/streams/syslog/SyslogClient.java
delete mode 100644 rocketmq-streams-clients/pom.xml
delete mode 100644 rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/source/DataStreamSource.java
delete mode 100644 rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/strategy/LogFingerprintStrategy.java
delete mode 100644 rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/strategy/WindowStrategy.java
delete mode 100644 rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/DataStream.java
delete mode 100644 rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/JoinStream.java
delete mode 100644 rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/OverWindowStream.java
delete mode 100644 rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/SplitStream.java
delete mode 100644 rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/WindowStream.java
delete mode 100644 rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/window/HoppingWindow.java
delete mode 100644 rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/window/SessionWindow.java
delete mode 100644 rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/window/TumblingWindow.java
delete mode 100644 rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/window/WindowInfo.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/ApplicationTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/DBDriverTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/DBSinkTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/DataStreamTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/FileTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/FilterTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/JoinTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/MqttSourceExample.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/ORMUtilTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/OnewayProducer.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/Person.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/RocketMQGroupByTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/RocketMQTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/ScriptOptimizationTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/ScriptTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/SinkTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/SourceTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/UnionTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/WindowTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/CountFromFileTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/CountSupportEmitTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/JoinTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/SplitTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/sink/UDFDefinedSQLParser.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/sink/UserDefinedSink.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/sink/UserDefinedSupportShuffleSink.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/source/MqttStreamsTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/AbstractWindowFireModeTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/AbstractWindowTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/MultiSplitTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/ShuffleOverWindowTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/SingleSplitTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/WindowDebugTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/WindowFireResultCompareTest.java
delete mode 100644 rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/WindowMsgManager.java
delete mode 100644 rocketmq-streams-clients/src/test/resources/dim.txt
delete mode 100755 rocketmq-streams-clients/src/test/resources/log4j.xml
delete mode 100644 rocketmq-streams-clients/src/test/resources/window_msg_10.txt
delete mode 100644 rocketmq-streams-clients/src/test/resources/window_msg_100.txt
delete mode 100644 rocketmq-streams-clients/src/test/resources/window_msg_1000.txt
delete mode 100644 rocketmq-streams-clients/src/test/resources/window_msg_10000.txt
delete mode 100644 rocketmq-streams-clients/src/test/resources/window_msg_88121.txt
delete mode 100755 rocketmq-streams-commons/pom.xml
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/batchsystem/BatchFinishMessage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/ByteArrayMemoryTable.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/FileBasedTable.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/HybridByteBufferTable.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/ListMemoryTable.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/MappedByteBufferTable.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/TableSchema.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/AbstractMemoryTable.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/AdditionStore.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/BigMapAddress.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/BitSetCache.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/ByteArray.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/ByteArrayValueKV.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/ByteStore.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/CacheKV.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/ICacheKV.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/KVAddress.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/KVElement.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/MappedByteBufferStore.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/impl/AbstractListKV.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/impl/FixedLenRowCacheKV.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/impl/IntValueKV.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/impl/KeySet.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/impl/LongListKV.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/impl/LongValueKV.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/impl/MapAddressListKV.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/impl/MultiValueKV.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/impl/MutilValueKV.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/impl/SplitCache.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/impl/StringValueKV.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/softreference/ICache.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/softreference/impl/SoftReferenceCache.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/calssscaner/AbstractScan.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/AbstractChannel.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/IChannel.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/builder/AbstractChannelSQLSupportShuffleSQLParser.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/builder/AbstractSupportShuffleChannelBuilder.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/builder/IChannelBuilder.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/builder/IShuffleChannelBuilder.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/CollectionSink.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/CollectionSinkBuilder.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/CollectionSource.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/CollectionSourceBuilder.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/OutputPrintChannel.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/PrintChannelBuilder.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/file/FileChannelBuilder.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/file/FileSink.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/file/FileSource.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/file/FileSplit.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/memory/MemoryCache.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/memory/MemoryChannel.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/memory/MemoryChannelBuilder.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/memory/MemorySink.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/memory/MemorySource.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/view/ViewChannelBuilder.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/view/ViewSink.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/view/ViewSource.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/sink/AbstractSink.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/sink/AbstractSupportShuffleSink.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/sink/AbstractSupportShuffleUDFSink.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/sink/AbstractUDFSink.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/sink/ISink.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/sinkcache/DataSourceAutoFlushTask.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/sinkcache/IMessageCache.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/sinkcache/IMessageFlushCallBack.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/sinkcache/impl/AbstractMultiSplitMessageCache.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/sinkcache/impl/MessageCache.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/sinkcache/impl/MultiSplitMessageCache.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/source/AbstractBatchSource.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/source/AbstractSource.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/source/AbstractUnreliableSource.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/source/ISource.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/source/ISplitChangedListener.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/source/systemmsg/ChangeTableNameMessage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/source/systemmsg/NewSplitMessage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/source/systemmsg/RemoveSplitMessage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/source/systemmsg/SplitChangedMessage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/split/ISplit.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/AbstractCheckPointStorage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/CheckPoint.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/CheckPointManager.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/CheckPointMessage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/CheckPointState.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/CheckPointStorageFactory.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/ICheckPoint.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/ICheckPointStorage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/SourceSnapShot.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/SourceState.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/classloader/ByteClassLoader.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/classloader/FileClassLoader.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/classloader/IsolationClassLoader.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/compiler/CustomJavaCompiler.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/component/AbstractComponent.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/component/ComponentCreator.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/component/ConfigureDescriptor.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/component/IComponent.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/component/PropertyConfigureDescriptorManager.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/component/PropertyConfigureDiscriptorManager.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configurable/AbstractConfigurable.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configurable/BasedConfigurable.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configurable/IAfterConfigurableRefreshListener.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configurable/IConfigurable.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configurable/IConfigurableIdentification.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configurable/IConfigurableService.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configurable/IFieldProcessor.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configurable/annotation/Changeable.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configurable/annotation/ENVDependence.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configurable/annotation/NoSerialized.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configure/ConfigureFileKey.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/configure/StreamsConfigure.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/AbstractContext.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/BatchMessageOffset.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/Context.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/IMessage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/Message.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/MessageHeader.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/MessageOffset.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/UserDefinedMessage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/ArrayDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/BaseDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/BooleanDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/ByteDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/ConfigurableDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/DataJsonable.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/DataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/DateDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/DateTimeDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/DoubleDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/FloatDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/GenericParameterDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/GenericParamterDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/HllDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/IJsonable.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/IntDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/JavaBeanDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/JsonableDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/ListDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/LongDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/MapDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/NotSupportDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/NumberDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/SerializableDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/SetDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/ShortDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/StringDataType.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/dboperator/IDBDriver.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/disruptor/DisruptorEventFactory.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/disruptor/DisruptorProducer.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/functions/FilterFunction.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/functions/ForEachFunction.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/functions/ForEachMessageFunction.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/functions/Function.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/functions/MapFunction.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/functions/MultiTableSplitFunction.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/functions/ReduceFunction.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/functions/SplitFunction.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/functions/TableSplitFunction.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/interfaces/IBaseStreamOperator.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/interfaces/IBatchMessageFinishNotify.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/interfaces/IFilterService.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/interfaces/IJDBCOperator.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/interfaces/IJsonobjectProcessor.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/interfaces/ILifeCycle.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/interfaces/ILineMessageProcessor.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/interfaces/IPropertyEnable.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/interfaces/IScheduleExecutor.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/interfaces/IStreamOperator.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/interfaces/ISystemMessageProcessor.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/logger/LoggerCreator.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/logger/LoggerOutputChannel.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/logger/MyDailyRollingFileAppender.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/metadata/AbstractMetaData.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/metadata/LogicMetaData.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/metadata/MetaData.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/metadata/MetaDataAdapter.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/metadata/MetaDataField.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/metadata/MetaDataUtils.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/model/Entity.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/model/NameCreator.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/model/NameCreatorContext.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/model/ServiceName.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/model/ThreadContext.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/ConsoleMonitorManager.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/DataSyncConstants.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/HttpClient.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/HttpUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/IMonitor.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/MonitorDataSyncServiceFactory.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/MonitorFactory.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/TopologyFilterMonitor.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/group/GroupedMonitorInfo.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/group/MonitorCommander.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/impl/DipperMonitor.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/impl/MonitorItem.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/impl/NothingMonitorItem.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/impl/NothingMontior.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/model/JobStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/model/TraceIdsDO.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/model/TraceMonitorDO.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/service/MonitorDataSyncService.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/service/impl/DBMonitorDataSyncImpl.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/service/impl/HttpMonitorDataSyncImpl.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/monitor/service/impl/RocketMQMonitorDataSyncImpl.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/FilterResultCache.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/HomologousVar.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/HyperscanEngine.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/IHomologousOptimization.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/IStreamRegex.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/LikeRegex.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/MessageGlobleTrace.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/OptimizationRegex.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/Re2Engine.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/RegexEngine.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/TaskOptimization.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/fingerprint/FingerprintCache.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/fingerprint/FingerprintMetric.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/optimization/fingerprint/PreFingerprint.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/schedule/IScheduleCondition.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/schedule/ScheduleManager.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/schedule/ScheduleTask.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/threadpool/ThreadPoolFactory.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/AbstractMutilPipelineChainPipline.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/ChainPipeline.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/ChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/SectionPipeline.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/builder/IStageBuilder.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/builder/PipelineBuilder.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/metric/NotFireReason.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/metric/StageGroup.java
delete 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/AbstractRule.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/model/AbstractScript.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/model/AbstractStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/model/IWindow.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/model/Pipeline.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/model/Union.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/shuffle/IShuffleKeyGenerator.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/shuffle/ShuffleMQCreator.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/AbstractStatelessChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/AbstractWindowStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/EmptyChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/FilterChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/JoinChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/JoinEndChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/JoinStartChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/NewSQLChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/OpenAPIChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/OutputChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/PythonChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/RightJoinChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/SQLChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/ScriptChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/ShuffleConsumerChainStage.java
delete 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/UnionChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/UnionEndChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/UnionStartChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/ViewChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/WindowChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/udf/IReducer.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/udf/MapOperator.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/udf/StageBuilder.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/udf/UDFChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/stages/udf/UDFUnionChainStage.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/task/StreamsTask.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/topology/task/TaskAssigner.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/transport/IFileTransport.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/AESUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/Base64Utils.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/ClassUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/CollectionUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/CommandUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/CompressUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/ConfigurableUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/ContantsUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/CreateTopicUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/DESUtils.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/DataTypeUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/DateUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/DipperThreadLocalUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/ENVUtile.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/FileUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/IOUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/IPUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/InstantiationUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/Ip2LongUtils.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/JarUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/JsonableUtil.java
delete 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/LogParserUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/MapKeyUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/MessageUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/NumberUtils.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/PipelineHTMLUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/PrintUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/PropertiesUtils.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/RandomStrUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/ReflectUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/RuntimeUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/SQLFormatterUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/SQLUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/ScheduleUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/SerializeUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/ServiceLoadUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/ShellUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/StringUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/SyslogParserUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/ThreadUtil.java
delete mode 100644 rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/TraceUtil.java
delete mode 100644 rocketmq-streams-commons/src/test/java/org/apache/rocketmq/streams/common/MessasgeCacheTest.java
delete mode 100644 rocketmq-streams-commons/src/test/java/org/apache/rocketmq/streams/common/cache/compress/BaseTest.java
delete mode 100644 rocketmq-streams-commons/src/test/java/org/apache/rocketmq/streams/common/cache/compress/HybridByteBufferTableTest.java
delete mode 100644 rocketmq-streams-commons/src/test/java/org/apache/rocketmq/streams/common/cache/compress/IntValueKVTest.java
delete mode 100644 rocketmq-streams-commons/src/test/java/org/apache/rocketmq/streams/common/cache/compress/MappedByteBufferTest.java
delete mode 100644 rocketmq-streams-commons/src/test/java/org/apache/rocketmq/streams/common/cache/compress/NumberUtilsTest.java
delete mode 100644 rocketmq-streams-commons/src/test/java/org/apache/rocketmq/streams/common/cache/softreference/SoftReferenceCacheTest.java
delete mode 100644 rocketmq-streams-commons/src/test/java/org/apache/rocketmq/streams/common/channel/SinkTest.java
delete mode 100644 rocketmq-streams-commons/src/test/java/org/apache/rocketmq/streams/common/channel/SourceTest.java
delete mode 100644 rocketmq-streams-commons/src/test/java/org/apache/rocketmq/streams/common/classscan/ClassScanTest.java
delete mode 100644 rocketmq-streams-commons/src/test/java/org/apache/rocketmq/streams/common/compiler/CustomJavaCompilerTest.java
delete mode 100644 rocketmq-streams-commons/src/test/java/org/apache/rocketmq/streams/common/datatype/DataTypeTest.java
delete mode 100644 rocketmq-streams-commons/src/test/java/org/apache/rocketmq/streams/common/regex/RegexTest.java
delete mode 100644 rocketmq-streams-commons/src/test/java/org/apache/rocketmq/streams/common/serializa/CountAccum.java
delete mode 100644 rocketmq-streams-commons/src/test/java/org/apache/rocketmq/streams/common/serializa/Person.java
delete mode 100644 rocketmq-streams-commons/src/test/java/org/apache/rocketmq/streams/common/serializa/SerializeTest.java
delete mode 100644 rocketmq-streams-commons/src/test/java/org/apache/rocketmq/streams/common/stages/SelfChainStageTest.java
delete mode 100755 rocketmq-streams-commons/src/test/resources/log4j.xml
delete mode 100755 rocketmq-streams-configurable/pom.xml
delete mode 100644 rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/ConfigurableComponent.java
delete mode 100644 rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/model/Configure.java
delete mode 100644 rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/AbstractConfigurableService.java
delete mode 100644 rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/AbstractSupportParentConfigureService.java
delete mode 100644 rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/ConfigurableServcieType.java
delete mode 100644 rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/ConfigurableServiceFactory.java
delete mode 100644 rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/impl/FileConfigureService.java
delete mode 100644 rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/impl/FileSupportParentConfigureService.java
delete mode 100644 rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/impl/HttpConfigureService.java
delete mode 100644 rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/impl/HttpSupportParentConfigureService.java
delete mode 100644 rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/impl/MemoryConfigureService.java
delete mode 100644 rocketmq-streams-configurable/src/main/java/org/apache/rocketmq/streams/configurable/service/impl/MemorySupportParentConfigureService.java
delete mode 100644 rocketmq-streams-configurable/src/test/java/org/apache/rocketmq/streams/configuable/ConfiguableComponentTest.java
delete mode 100644 rocketmq-streams-configurable/src/test/java/org/apache/rocketmq/streams/configuable/model/Person.java
delete mode 100755 rocketmq-streams-configurable/src/test/resources/log4j.xml
delete mode 100755 rocketmq-streams-db-operator/pom.xml
delete mode 100644 rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/configuable/DBConfigureService.java
delete mode 100644 rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/configuable/DBSupportParentConfigureService.java
delete mode 100644 rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/driver/DriverBuilder.java
delete mode 100644 rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/driver/IDriverBudiler.java
delete mode 100644 rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/driver/JDBCDriver.java
delete mode 100644 rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/driver/batchloader/BatchRowLoader.java
delete mode 100644 rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/driver/batchloader/IRowOperator.java
delete mode 100644 rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/driver/orm/ORMUtil.java
delete mode 100644 rocketmq-streams-db-operator/src/main/java/org/apache/rocketmq/streams/db/operator/SQLOperator.java
delete mode 100644 rocketmq-streams-db-operator/src/test/java/org/apache/rocketmq/streams/db/Person.java
delete mode 100644 rocketmq-streams-db-operator/src/test/java/org/apache/rocketmq/streams/db/configuable/DBSupportParentConfigureServiceTest.java
delete mode 100644 rocketmq-streams-db-operator/src/test/java/org/apache/rocketmq/streams/db/driver/orm/ORMUtilTest.java
delete mode 100644 rocketmq-streams-dbinit/src/main/resources/tables_mysql_innodb.sql
delete mode 100644 rocketmq-streams-examples/README.md
delete mode 100644 rocketmq-streams-examples/pom.xml
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/Constant.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/PageDimensionExample.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/RocketMQWindowExample.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/UsersDimensionExample.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/join/RocketmqJoinExample.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/mutilconsumer/MultiStreamsExample.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/schema/CustomeDeserializerExample.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/schema/DataDeserializer.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/schema/SchemaRocketmqExample.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/schema/SchemaRocketmqWindowExample.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/schema/WordCountExample.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/send/ProducerFromFile.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/send/SendMessageContinuously.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/send/SendMessageOnce.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/sink/MqttSinkExample.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/Data.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/FileSourceExample.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/RocketmqSourceExample1.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/RocketmqSourceExample2.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/RocketmqSourceExample3.java
delete mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/RocketmqSourceExample4.java
delete mode 100644 rocketmq-streams-examples/src/main/resources/data-2.txt
delete mode 100644 rocketmq-streams-examples/src/main/resources/data.txt
delete mode 100644 rocketmq-streams-examples/src/main/resources/joinData-1.txt
delete mode 100644 rocketmq-streams-examples/src/main/resources/joinData-2.txt
delete mode 100644 rocketmq-streams-examples/src/main/resources/pageClickData.txt
delete mode 100644 rocketmq-streams-examples/src/main/resources/scores.txt
delete mode 100644 rocketmq-streams-examples/src/main/resources/word.txt
delete mode 100755 rocketmq-streams-filter/pom.xml
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/FilterComponent.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/builder/ExpressionBuilder.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/builder/RuleBuilder.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/builder/RuleElementBuilder.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/contants/RuleElementType.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/context/ContextConfigure.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/context/RuleContext.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/context/RuleMessage.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/engine/IRuleEngine.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/engine/SplitFlow.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/engine/impl/DefaultRuleEngine.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/exception/RegexTimeoutException.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/etl/RenameFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/AbstractExpressionFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/CompareFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/ContainsCaseInsensitiveFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/ContainsFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/Equals.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/ExpressionFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/GreaterEquals.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/GreaterThan.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/InFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/InMetaData.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/IpContainsFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/IsNotNull.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/IsNull.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/LessEquals.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/LessThan.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/LikeFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/NotContainsCaseInsensitiveFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/NotContainsFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/NotEquals.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/NotInFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/NotLikeFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/NotRegexCaseInsensitiveFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/NotRegexFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/RegexCaseInsensitiveFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/RegexFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/expression/ScriptFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/script/CaseDependentParser.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/function/script/CaseFunction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/monitor/Monitor.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/monitor/rule/ActionMonitor.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/monitor/rule/ExpressionMonitor.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/monitor/rule/MessageMonitor.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/monitor/rule/RuleMonitor.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/monitor/rule/VarMonitor.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/FilterOperator.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/Rule.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/RuleExpression.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/action/Action.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/action/IConfigurableAction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/action/impl/SinkAction.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/Expression.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/ExpressionPerformance.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/ExpressionRelationParser.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/GroupExpression.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/GroupExpressionManager.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/OptimizationRule.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/RelationExpression.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/expression/SimpleExpression.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/var/ConstantVar.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/var/ContextVar.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/var/InnerVar.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/operator/var/Var.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/ExpressionOptimization.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/PiplineLogFingerprintAnalysis.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/casewhen/AbstractWhenExpression.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/casewhen/CaseWhenBuilder.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/casewhen/CaseWhenElement.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/casewhen/GroupByVarCaseWhen.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/casewhen/MutilCaseWhenExpression.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/casewhen/SingleCaseWhenExpression.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/dependency/BlinkRule.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/dependency/BlinkRuleV2Expression.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/dependency/CommonExpression.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/dependency/DependencyTree.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/dependency/FilterTreeNode.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/dependency/PipelineTree.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/dependency/ScriptDependent.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/dependency/ScriptTreeNode.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/dependency/SimplePipelineTree.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/dependency/StateLessDependencyTree.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/dependency/TreeNode.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/executor/AbstractExecutor.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/executor/GroupByVarExecutor.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/executor/HyperscanExecutor.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/homologous/HomologousCompute.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/homologous/HomologousOptimization.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/result/GroupQuickFilterResult.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/optimization/script/ScriptOptimization.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/service/IRuleEngineService.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/service/impl/RuleEngineServiceImpl.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/utils/IPUtil.java
delete mode 100644 rocketmq-streams-filter/src/main/java/org/apache/rocketmq/streams/filter/utils/RegexUtil.java
delete mode 100644 rocketmq-streams-filter/src/test/java/org/apache/rocketmq/streams/filter/FilterComponentTest.java
delete mode 100644 rocketmq-streams-filter/src/test/java/org/apache/rocketmq/streams/filter/operator/ExpressionTest.java
delete mode 100755 rocketmq-streams-filter/src/test/resources/log4j.xml
delete mode 100755 rocketmq-streams-script/pom.xml
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/ScriptComponent.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/annotation/Function.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/annotation/FunctionMethod.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/annotation/FunctionMethodAilas.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/annotation/FunctionParamter.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/annotation/UDAFFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/context/FunctionContext.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/aggregation/AverageAccumulator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/aggregation/ConcatAccumulator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/aggregation/ConcatDistinctAccumulator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/aggregation/CountAccumulator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/aggregation/CountDistinctAccumulator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/aggregation/DistinctAccumulator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/aggregation/DistinctAccumulator2.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/aggregation/FirstValueAccumulator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/aggregation/LastValueAccumulator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/aggregation/MaxAccumulator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/aggregation/MinAccumulator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/aggregation/SumAccum.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/aggregation/SumAccumulator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/between/BetweenFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/bool/BooleanFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/common/EchoFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/condition/EqualsFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/condition/ExecuteByConditionFuction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/condition/GreateEqualsFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/condition/GreaterFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/condition/IFFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/condition/IFScopeFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/condition/InConditionFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/condition/LessEqualsFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/condition/LessFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/context/ContextFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/AddMonthFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/CurrentTimestampFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/DateAddFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/DateDiffFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/DateFormatFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/DatePartFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/DateToCharFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/DateTruncFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/DateUtilFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/DateUtileFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/DayFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/FromUnixTimeFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/GetDateFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/IsDateFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/LastDayFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/NextDayFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/NowFuntion.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/QuarterFuction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/QuarterFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/UnixTimeStampFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/WeekOfYearFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/date/WeekdayFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/distinct/DistinctFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/env/ENVFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/eval/EvalFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/field/AdditionalFiledFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/field/CoalesceFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/field/ExtraFieldFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/field/FieldFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/field/RemoveFieldFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/field/RetainFieldFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/filter/BreakFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/filter/FilterFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/flatmap/SplitArrayFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/flatmap/SplitJsonArrayFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/header/HeaderFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/item/ItemFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/json/JsonArrayFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/json/JsonCreatorFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/json/JsonValueFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/json/UDTFFieldNameFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/AbsFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/AcosFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/AdditionFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/AsinFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/AtanFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/BinFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/BitFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/BroundFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/CardinalityFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/CbrtFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/CeilFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/ConvFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/CosFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/CosHFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/CotFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/DegreesFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/DivisionFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/EFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/ExpFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/FactorialFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/FloorFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/HexFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/IsDecimalFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/LnFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/Log10Function.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/Log2Function.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/LogFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/MathFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/MultiplicationFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/OperationFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/PIFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/PowerFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/RadiansFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/RandFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/RoundFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/ShiftLeftFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/ShiftRightFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/ShiftRightUnSignedFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/SignFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/SinFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/SinHFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/SqrtFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/SubtractionFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/TanFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/TanHFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/TruncFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/math/UnHexFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/mock/MockFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/offset/OffsetFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/parser/GrokFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/parser/LogParserFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/parser/Paser2JsonFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/parser/PaserBySplitFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/parser/RegexParserFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/python/GroovyFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/python/PythonFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/relation/AndFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/router/RouteFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/sql/SQLFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/AsciiFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/Base64Function.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/BlinkStringFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/CharMatchCountFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/ChrFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/HashCodeFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/InitCapFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/InstrFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/InstrtFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/Ip2RegionFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/IsEncodingFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/KeyValueFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/LTrimFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/LengthBFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/LengthFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/Md5Function.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/NullFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/ParseUrlFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/RTrimFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/RegexCountFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/RegexFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/RegexInstrFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/RegexReplaceFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/RegexSubStrFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/RepeatFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/ReplaceFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/ReverseFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/SoundxFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/SpaceFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/SplitPartFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/String2Map.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/SubStringIndexFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/ToCharFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/ToLowerFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/ToUpperFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/TransLateFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/TrimFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/UUIDFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/UrlDecodeFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/string/UrlEncodeFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/type/CastFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/udtf/UDTFFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/impl/window/WindowFunction.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/model/FunctionConfigure.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/model/FunctionConfigureMap.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/model/FunctionInfo.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/model/FunctionInfoMap.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/service/IDipperInterfaceAdpater.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/service/IFunctionService.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/service/impl/DefaultFunctionServiceImpl.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/service/impl/ScanFunctionService.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/operator/AbstractScriptOperator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/operator/expression/GroupScriptExpression.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/operator/expression/ICaseDependentParser.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/operator/expression/ScriptExpression.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/operator/expression/ScriptParameter.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/operator/impl/AggregationScript.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/operator/impl/FileGroovyScriptOperator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/operator/impl/FileJPythonScriptOperatore.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/operator/impl/FunctionScript.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/operator/impl/GroovyScriptOperator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/operator/impl/JPythonScriptOperator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/operator/impl/JavaScriptOperator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/operator/impl/ScriptOperator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/compile/CompileParameter.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/compile/CompileScriptExpression.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/optimization/performance/IScriptOptimization.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/parser/IScriptExpressionParser.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/parser/ScriptExpressionParserFactory.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/parser/imp/ConditionExpressionParser.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/parser/imp/FunctionExpressionParser.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/parser/imp/FunctionParser.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/service/IAccumulator.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/service/IFunctionFieldDependent.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/service/IScriptExpression.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/service/IScriptParamter.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/service/IScriptService.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/service/IScriptUDFInit.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/service/IUDFScan.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/service/impl/ScriptServiceImpl.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/service/udf/SimpleUDAFScript.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/service/udf/UDAFScript.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/service/udf/UDFScript.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/service/udf/UDTFScript.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/utils/ExpressionUtil.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/utils/FunctionUtils.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/utils/MatchUtil.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/utils/RandomStrUtil.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/utils/ScriptParserUtil.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/utils/StringMatchUtil.java
delete mode 100644 rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/utils/UniqID.java
delete mode 100644 rocketmq-streams-script/src/test/java/org/apache/rocketmq/streams/script/function/FunctionTest.java
delete mode 100644 rocketmq-streams-script/src/test/java/org/apache/rocketmq/streams/script/function/GrokFunctionTest.java
delete mode 100644 rocketmq-streams-script/src/test/java/org/apache/rocketmq/streams/script/function/GroovyFunctionTest.java
delete mode 100644 rocketmq-streams-script/src/test/java/org/apache/rocketmq/streams/script/function/JPythonFunctionTest.java
delete mode 100644 rocketmq-streams-script/src/test/java/org/apache/rocketmq/streams/script/function/UDTFFunctionTest.java
delete mode 100644 rocketmq-streams-script/src/test/java/org/apache/rocketmq/streams/script/function/aggregation/AccumulatorTest.java
delete mode 100644 rocketmq-streams-script/src/test/java/org/apache/rocketmq/streams/script/function/function/JavaObjectUDFFunction.java
delete mode 100644 rocketmq-streams-script/src/test/java/org/apache/rocketmq/streams/script/operator/ScriptOperatorTest.java
delete mode 100644 rocketmq-streams-script/src/test/java/org/apache/rocketmq/streams/script/parser/ScriptParserTest.java
delete mode 100755 rocketmq-streams-script/src/test/resources/log4j.xml
delete mode 100755 rocketmq-streams-serviceloader/pom.xml
delete mode 100644 rocketmq-streams-serviceloader/src/main/java/org/apache/rocketmq/streams/serviceloader/IServiceLoaderService.java
delete mode 100644 rocketmq-streams-serviceloader/src/main/java/org/apache/rocketmq/streams/serviceloader/ServiceLoaderComponent.java
delete mode 100644 rocketmq-streams-serviceloader/src/main/java/org/apache/rocketmq/streams/serviceloader/namefinder/IServiceNameGetter.java
delete mode 100644 rocketmq-streams-serviceloader/src/main/java/org/apache/rocketmq/streams/serviceloader/namefinder/impl/AnnotationServiceNameGetter.java
delete mode 100644 rocketmq-streams-serviceloader/src/main/java/org/apache/rocketmq/streams/serviceloader/utils/FileUtil.java
delete mode 100644 rocketmq-streams-serviceloader/src/test/java/org/apache/rocketmq/streams/serviceloader/ServiceLoaderComponentTest.java
delete mode 100755 rocketmq-streams-serviceloader/src/test/resources/log4j.xml
delete mode 100644 rocketmq-streams-state/pom.xml
delete mode 100644 rocketmq-streams-state/src/main/java/org/apache/rocketmq/streams/state/AbstractState.java
delete mode 100644 rocketmq-streams-state/src/main/java/org/apache/rocketmq/streams/state/IEntryProcessor.java
delete mode 100644 rocketmq-streams-state/src/main/java/org/apache/rocketmq/streams/state/ISchama.java
delete mode 100644 rocketmq-streams-state/src/main/java/org/apache/rocketmq/streams/state/IState.java
delete mode 100644 rocketmq-streams-state/src/main/java/org/apache/rocketmq/streams/state/LruState.java
delete mode 100644 rocketmq-streams-state/src/main/java/org/apache/rocketmq/streams/state/backend/IStateBackend.java
delete mode 100644 rocketmq-streams-state/src/main/java/org/apache/rocketmq/streams/state/impl/MapState.java
delete mode 100644 rocketmq-streams-state/src/main/java/org/apache/rocketmq/streams/state/kv/IKvState.java
delete mode 100644 rocketmq-streams-state/src/main/java/org/apache/rocketmq/streams/state/kv/rocksdb/RocksDBOperator.java
delete mode 100644 rocketmq-streams-state/src/main/java/org/apache/rocketmq/streams/state/kv/rocksdb/RocksdbState.java
delete mode 100644 rocketmq-streams-state/src/test/java/org/apache/rocketmq/streams/state/kv/TestLruState.java
delete mode 100644 rocketmq-streams-state/src/test/java/org/apache/rocketmq/streams/state/kv/TestRocksdbState.java
delete mode 100755 rocketmq-streams-state/src/test/resources/log4j.xml
delete mode 100755 rocketmq-streams-transport-minio/pom.xml
delete mode 100644 rocketmq-streams-transport-minio/src/main/java/org/apache/rocketmq/streams/transport/minio/MinioFileTransport.java
delete mode 100644 rocketmq-streams-transport-minio/src/test/java/org/apache/rocketmq/streams/configuable/model/DataTpyeTest.java
delete mode 100644 rocketmq-streams-transport-minio/src/test/java/org/apache/rocketmq/streams/configuable/model/Person.java
delete mode 100644 rocketmq-streams-transport-minio/src/test/java/org/apache/rocketmq/streams/configurable/model/Person.java
delete mode 100755 rocketmq-streams-transport-minio/src/test/resources/log4j.xml
delete mode 100755 rocketmq-streams-window/pom.xml
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/builder/WindowBuilder.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/debug/DebugAnalysis.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/debug/DebugWriter.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/debug/WindowDebug.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/fire/EventTimeManager.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/fire/SplitEventTimeManager.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/minibatch/ShuffleMessageCache.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/model/FireMode.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/model/FunctionExecutor.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/model/WindowCache.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/model/WindowInstance.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/AbstractShuffleWindow.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/AbstractWindow.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/impl/OverWindow.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/impl/SessionOperator.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/impl/ShuffleOverWindow.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/impl/TopNState.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/impl/WindowOperator.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/join/ExpressionMatcher.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/join/JoinWindow.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/shuffle/AbstractSystemChannel.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/shuffle/ShuffleCache.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/shuffle/ShuffleChannel.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/source/WindowShuffleSource.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/state/AbstractMapState.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/state/WindowBaseValue.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/state/impl/JoinLeftState.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/state/impl/JoinRightState.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/state/impl/JoinState.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/state/impl/WindowValue.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/AbstractStorage.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/DataType.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/IStorage.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/RocksdbIterator.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/WindowInstanceIterator.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/WindowJoinType.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/WindowType.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/rocketmq/DefaultStorage.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/rocksdb/RocksdbStorage.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/trigger/WindowTrigger.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/util/ShuffleUtil.java
delete mode 100644 rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/util/WindowChannellUtil.java
delete mode 100644 rocketmq-streams-window/src/test/java/org/apache/rocketmq/streams/RocksdbTest.java
delete mode 100644 rocketmq-streams-window/src/test/java/org/apache/rocketmq/streams/configruation/model/Person.java
delete mode 100644 rocketmq-streams-window/src/test/java/org/apache/rocketmq/streams/configurable/model/Person.java
delete mode 100644 rocketmq-streams-window/src/test/java/org/apache/rocketmq/streams/storage/RocksdbTest.java
delete mode 100644 rocketmq-streams-window/src/test/java/org/apache/rocketmq/streams/window/WindowInstanceTest.java
delete mode 100644 rocketmq-streams-window/src/test/java/org/apache/rocketmq/streams/window/WindowValueTest.java
delete mode 100755 rocketmq-streams-window/src/test/resources/log4j.xml