This is an automated email from the ASF dual-hosted git repository. zhoubo pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
commit ce39378b07f04c3deb8ceaed88cd51df7e19381c Merge: 5feab9c 4fdd8b2 Author: odbozhou <[email protected]> AuthorDate: Wed Mar 2 11:23:24 2022 +0800 Add 'connector/rocketmq-connect-redis/' from commit '4fdd8b2e20c4d815e7bd5c9cef13be89fcd56c02' git-subtree-dir: connector/rocketmq-connect-redis git-subtree-mainline: 5feab9cd053c7fa6b7b64cfeac5af860f58bd725 git-subtree-split: 4fdd8b2e20c4d815e7bd5c9cef13be89fcd56c02 connector/rocketmq-connect-redis/README-CN.md | 19 + connector/rocketmq-connect-redis/README.md | 19 + connector/rocketmq-connect-redis/pom.xml | 208 ++++ .../rocketmq/connect/redis/common/Config.java | 237 +++++ .../rocketmq/connect/redis/common/Options.java | 124 +++ .../connect/redis/common/RedisConstants.java | 46 + .../rocketmq/connect/redis/common/SyncMod.java | 37 + .../redis/connector/RedisSourceConnector.java | 70 ++ .../connect/redis/connector/RedisSourceTask.java | 148 +++ .../connect/redis/converter/KVEntryConverter.java | 28 + .../redis/converter/RedisEntryConverter.java | 134 +++ .../redis/converter/RedisPositionConverter.java | 54 + .../redis/handler/DefaultRedisEventHandler.java | 174 +++ .../connect/redis/handler/RedisEventHandler.java | 72 ++ .../redis/parser/AbstractCommandParser.java | 82 ++ .../connect/redis/parser/AppendParser.java | 38 + .../connect/redis/parser/BitFieldParser.java | 32 + .../rocketmq/connect/redis/parser/BitOpParser.java | 41 + .../connect/redis/parser/BrPopLPushParser.java | 41 + .../connect/redis/parser/CommonParser.java | 117 +++ .../connect/redis/parser/DecrByParser.java | 38 + .../rocketmq/connect/redis/parser/DecrParser.java | 32 + .../redis/parser/DefaultRedisRdbParser.java | 197 ++++ .../rocketmq/connect/redis/parser/DelParser.java | 46 + .../rocketmq/connect/redis/parser/EvalParser.java | 38 + .../connect/redis/parser/EvalShaParser.java | 38 + .../rocketmq/connect/redis/parser/ExecParser.java | 32 + .../connect/redis/parser/ExpireAtParser.java | 38 + .../connect/redis/parser/ExpireParser.java | 40 + .../connect/redis/parser/FlushAllParser.java | 32 + .../connect/redis/parser/FlushDbParser.java | 33 + .../connect/redis/parser/GeoAddParser.java | 49 + .../connect/redis/parser/GetsetParser.java | 37 + .../rocketmq/connect/redis/parser/HDelParser.java | 41 + .../connect/redis/parser/HIncrByParser.java | 41 + .../connect/redis/parser/HSetNxParser.java | 37 + .../rocketmq/connect/redis/parser/HSetParser.java | 37 + .../rocketmq/connect/redis/parser/HmSetParser.java | 37 + .../connect/redis/parser/IncrByParser.java | 38 + .../rocketmq/connect/redis/parser/IncrParser.java | 32 + .../rocketmq/connect/redis/parser/LPopParser.java | 32 + .../rocketmq/connect/redis/parser/LPushParser.java | 41 + .../connect/redis/parser/LPushXParser.java | 37 + .../rocketmq/connect/redis/parser/LRemParser.java | 41 + .../rocketmq/connect/redis/parser/LSetParser.java | 41 + .../rocketmq/connect/redis/parser/LTrimParser.java | 41 + .../connect/redis/parser/LinsertParser.java | 51 + .../connect/redis/parser/MSetNxParser.java | 37 + .../rocketmq/connect/redis/parser/MSetParser.java | 37 + .../rocketmq/connect/redis/parser/MoveParser.java | 38 + .../rocketmq/connect/redis/parser/MultiParser.java | 32 + .../connect/redis/parser/PExpireAtParser.java | 38 + .../connect/redis/parser/PExpireParser.java | 38 + .../connect/redis/parser/PSetExParser.java | 41 + .../rocketmq/connect/redis/parser/Parser.java | 24 + .../connect/redis/parser/PersistParser.java | 32 + .../rocketmq/connect/redis/parser/PfAddParser.java | 41 + .../connect/redis/parser/PfCountParser.java | 37 + .../connect/redis/parser/PfMergeParser.java | 41 + .../connect/redis/parser/PublishParser.java | 37 + .../connect/redis/parser/RPopLPushParser.java | 37 + .../rocketmq/connect/redis/parser/RPopParser.java | 32 + .../rocketmq/connect/redis/parser/RPushParser.java | 41 + .../connect/redis/parser/RPushXParser.java | 37 + .../connect/redis/parser/RedisRdbParser.java | 67 ++ .../connect/redis/parser/RenameNxParser.java | 37 + .../connect/redis/parser/RenameParser.java | 37 + .../connect/redis/parser/RestoreParser.java | 45 + .../rocketmq/connect/redis/parser/SAddParser.java | 41 + .../connect/redis/parser/SDiffStoreParser.java | 41 + .../connect/redis/parser/SInterStoreParser.java | 41 + .../rocketmq/connect/redis/parser/SMoveParser.java | 41 + .../rocketmq/connect/redis/parser/SRemParser.java | 41 + .../connect/redis/parser/SUnionStoreParser.java | 41 + .../connect/redis/parser/ScriptParser.java | 32 + .../connect/redis/parser/SelectParser.java | 38 + .../connect/redis/parser/SetBitParser.java | 41 + .../rocketmq/connect/redis/parser/SetExParser.java | 42 + .../rocketmq/connect/redis/parser/SetNxParser.java | 37 + .../rocketmq/connect/redis/parser/SetParser.java | 59 ++ .../connect/redis/parser/SetRangeParser.java | 41 + .../rocketmq/connect/redis/parser/SortParser.java | 32 + .../connect/redis/parser/SwapDbParser.java | 38 + .../connect/redis/parser/UnLinkParser.java | 37 + .../rocketmq/connect/redis/parser/XAckParser.java | 49 + .../rocketmq/connect/redis/parser/XAddParser.java | 46 + .../connect/redis/parser/XClaimParser.java | 88 ++ .../rocketmq/connect/redis/parser/XDelParser.java | 41 + .../connect/redis/parser/XGroupParser.java | 32 + .../connect/redis/parser/XSetIdParser.java | 37 + .../rocketmq/connect/redis/parser/XTrimParser.java | 43 + .../rocketmq/connect/redis/parser/ZAddParser.java | 69 ++ .../connect/redis/parser/ZIncrByParser.java | 41 + .../connect/redis/parser/ZInterStoreParser.java | 37 + .../connect/redis/parser/ZPopMaxParser.java | 38 + .../connect/redis/parser/ZPopMinParser.java | 38 + .../rocketmq/connect/redis/parser/ZRemParser.java | 41 + .../connect/redis/parser/ZRemRangeByLexParser.java | 41 + .../redis/parser/ZRemRangeByRankParser.java | 41 + .../redis/parser/ZRemRangeByScoreParser.java | 41 + .../connect/redis/parser/ZUnionStoreParser.java | 37 + .../apache/rocketmq/connect/redis/pojo/Geo.java | 48 + .../rocketmq/connect/redis/pojo/KVEntry.java | 71 ++ .../rocketmq/connect/redis/pojo/RedisEntry.java | 171 +++ .../rocketmq/connect/redis/pojo/RedisEvent.java | 59 ++ .../processor/DefaultRedisEventProcessor.java | 453 ++++++++ .../redis/processor/RedisClosedListener.java | 37 + .../redis/processor/RedisEventListener.java | 121 +++ .../redis/processor/RedisEventProcessor.java | 40 + .../processor/RedisEventProcessorCallback.java | 23 + .../redis/processor/RedisExceptionListener.java | 44 + .../connect/redis/util/ParseStringUtils.java | 54 + .../connect/redis/util/PropertyToObjectUtils.java | 64 ++ .../rocketmq/redis/test/common/ConfigTest.java | 107 ++ .../rocketmq/redis/test/common/OptionsTest.java | 34 + .../test/connector/RedisSourceConnectorTest.java | 35 + .../redis/test/connector/RedisSourceTaskTest.java | 150 +++ .../test/converter/RedisEntryConverterTest.java | 118 +++ .../test/converter/RedisPositionConverterTest.java | 51 + .../redis/test/handler/RedisEventHandlerTest.java | 468 +++++++++ .../rocketmq/redis/test/parser/ParserTest.java | 1108 ++++++++++++++++++++ .../apache/rocketmq/redis/test/pojo/GeoTest.java | 19 + .../rocketmq/redis/test/pojo/KVEntryTest.java | 85 ++ .../rocketmq/redis/test/pojo/RedisEventTest.java | 33 + .../redis/test/processor/ListenerTest.java | 135 +++ .../redis/test/processor/ProcessorTest.java | 193 ++++ .../redis/test/util/ParseStringUtilsTest.java | 45 + .../redis/test/util/PropertyToObjectUtilsTest.java | 118 +++ .../style/copyright/Apache.xml | 23 + .../style/copyright/profiles_settings.xml | 64 ++ .../style/rmq_checkstyle.xml | 134 +++ .../rocketmq-connect-redis/style/rmq_codeStyle.xml | 143 +++ 132 files changed, 9375 insertions(+) diff --cc connector/rocketmq-connect-redis/README-CN.md index 0000000,786b0d6..786b0d6 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/README-CN.md +++ b/connector/rocketmq-connect-redis/README-CN.md diff --cc connector/rocketmq-connect-redis/README.md index 0000000,6da01d7..6da01d7 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/README.md +++ b/connector/rocketmq-connect-redis/README.md diff --cc connector/rocketmq-connect-redis/pom.xml index 0000000,62f7950..62f7950 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/pom.xml +++ b/connector/rocketmq-connect-redis/pom.xml diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java index 0000000,fe41075..fe41075 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Options.java index 0000000,71cc07f..71cc07f mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Options.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Options.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/RedisConstants.java index 0000000,fd01c13..fd01c13 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/RedisConstants.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/RedisConstants.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/SyncMod.java index 0000000,9ad2093..9ad2093 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/SyncMod.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/SyncMod.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java index 0000000,fde9f92..fde9f92 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceTask.java index 0000000,1b97836..1b97836 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceTask.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceTask.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/KVEntryConverter.java index 0000000,de1b8ca..de1b8ca mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/KVEntryConverter.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/KVEntryConverter.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisEntryConverter.java index 0000000,23de075..23de075 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisEntryConverter.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisEntryConverter.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisPositionConverter.java index 0000000,37e9e98..37e9e98 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisPositionConverter.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisPositionConverter.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/DefaultRedisEventHandler.java index 0000000,14362b9..14362b9 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/DefaultRedisEventHandler.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/DefaultRedisEventHandler.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/RedisEventHandler.java index 0000000,6f93b2d..6f93b2d mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/RedisEventHandler.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/RedisEventHandler.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AbstractCommandParser.java index 0000000,bf67b7d..bf67b7d mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AbstractCommandParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AbstractCommandParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java index 0000000,67c5a76..67c5a76 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitFieldParser.java index 0000000,55c7ce0..55c7ce0 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitFieldParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitFieldParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitOpParser.java index 0000000,38b1b71..38b1b71 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitOpParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitOpParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BrPopLPushParser.java index 0000000,bd8a090..bd8a090 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BrPopLPushParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BrPopLPushParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/CommonParser.java index 0000000,f8dca37..f8dca37 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/CommonParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/CommonParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrByParser.java index 0000000,edfad48..edfad48 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrByParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrByParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrParser.java index 0000000,c632603..c632603 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DefaultRedisRdbParser.java index 0000000,9a4c3ad..9a4c3ad mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DefaultRedisRdbParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DefaultRedisRdbParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DelParser.java index 0000000,17ae917..17ae917 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DelParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DelParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalParser.java index 0000000,deb36c1..deb36c1 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalShaParser.java index 0000000,38b564e..38b564e mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalShaParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalShaParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExecParser.java index 0000000,0b48a59..0b48a59 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExecParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExecParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireAtParser.java index 0000000,e04606c..e04606c mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireAtParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireAtParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireParser.java index 0000000,7a47de7..7a47de7 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushAllParser.java index 0000000,7db9603..7db9603 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushAllParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushAllParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushDbParser.java index 0000000,908d456..908d456 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushDbParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushDbParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GeoAddParser.java index 0000000,7136787..7136787 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GeoAddParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GeoAddParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GetsetParser.java index 0000000,1c816fc..1c816fc mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GetsetParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GetsetParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HDelParser.java index 0000000,9b17875..9b17875 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HDelParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HDelParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HIncrByParser.java index 0000000,7547740..7547740 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HIncrByParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HIncrByParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetNxParser.java index 0000000,02268d0..02268d0 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetNxParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetNxParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetParser.java index 0000000,87dcc33..87dcc33 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HmSetParser.java index 0000000,4e317e4..4e317e4 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HmSetParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HmSetParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrByParser.java index 0000000,d691955..d691955 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrByParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrByParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrParser.java index 0000000,db0402b..db0402b mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPopParser.java index 0000000,cc92668..cc92668 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPopParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPopParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushParser.java index 0000000,68672cf..68672cf mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushXParser.java index 0000000,bc301a5..bc301a5 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushXParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushXParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LRemParser.java index 0000000,6716061..6716061 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LRemParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LRemParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LSetParser.java index 0000000,be6fed4..be6fed4 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LSetParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LSetParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LTrimParser.java index 0000000,39a4386..39a4386 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LTrimParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LTrimParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LinsertParser.java index 0000000,c3d65b6..c3d65b6 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LinsertParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LinsertParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetNxParser.java index 0000000,8b13652..8b13652 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetNxParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetNxParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetParser.java index 0000000,34f9f11..34f9f11 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MoveParser.java index 0000000,0173086..0173086 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MoveParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MoveParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MultiParser.java index 0000000,cd32b16..cd32b16 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MultiParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MultiParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireAtParser.java index 0000000,0390de0..0390de0 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireAtParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireAtParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireParser.java index 0000000,efeee21..efeee21 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PSetExParser.java index 0000000,7ed476e..7ed476e mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PSetExParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PSetExParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/Parser.java index 0000000,b9a4b12..b9a4b12 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/Parser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/Parser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PersistParser.java index 0000000,6bfb2d0..6bfb2d0 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PersistParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PersistParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfAddParser.java index 0000000,51cfda2..51cfda2 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfAddParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfAddParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfCountParser.java index 0000000,fe674d9..fe674d9 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfCountParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfCountParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfMergeParser.java index 0000000,650c75b..650c75b mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfMergeParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfMergeParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PublishParser.java index 0000000,0d5d235..0d5d235 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PublishParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PublishParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopLPushParser.java index 0000000,38edce3..38edce3 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopLPushParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopLPushParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopParser.java index 0000000,85f122a..85f122a mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushParser.java index 0000000,8824d0b..8824d0b mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushXParser.java index 0000000,de2d21b..de2d21b mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushXParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushXParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RedisRdbParser.java index 0000000,fa4e46a..fa4e46a mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RedisRdbParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RedisRdbParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameNxParser.java index 0000000,14f4c4f..14f4c4f mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameNxParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameNxParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameParser.java index 0000000,9de8fe3..9de8fe3 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RestoreParser.java index 0000000,53a4569..53a4569 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RestoreParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RestoreParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SAddParser.java index 0000000,bb89eff..bb89eff mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SAddParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SAddParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SDiffStoreParser.java index 0000000,dc5ca3e..dc5ca3e mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SDiffStoreParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SDiffStoreParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SInterStoreParser.java index 0000000,be52db7..be52db7 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SInterStoreParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SInterStoreParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SMoveParser.java index 0000000,62007bb..62007bb mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SMoveParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SMoveParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SRemParser.java index 0000000,f51ad00..f51ad00 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SRemParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SRemParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SUnionStoreParser.java index 0000000,d821aba..d821aba mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SUnionStoreParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SUnionStoreParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ScriptParser.java index 0000000,746edb2..746edb2 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ScriptParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ScriptParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SelectParser.java index 0000000,a6ba72f..a6ba72f mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SelectParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SelectParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetBitParser.java index 0000000,b7b9495..b7b9495 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetBitParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetBitParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetExParser.java index 0000000,4c41260..4c41260 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetExParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetExParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetNxParser.java index 0000000,ba784b0..ba784b0 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetNxParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetNxParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java index 0000000,c0afe71..c0afe71 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetRangeParser.java index 0000000,61b3c39..61b3c39 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetRangeParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetRangeParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SortParser.java index 0000000,0888917..0888917 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SortParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SortParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SwapDbParser.java index 0000000,27d7a33..27d7a33 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SwapDbParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SwapDbParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/UnLinkParser.java index 0000000,6ee98ce..6ee98ce mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/UnLinkParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/UnLinkParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAckParser.java index 0000000,7c2e2c9..7c2e2c9 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAckParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAckParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAddParser.java index 0000000,755c267..755c267 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAddParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAddParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XClaimParser.java index 0000000,d3a2aa0..d3a2aa0 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XClaimParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XClaimParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XDelParser.java index 0000000,f1dcefa..f1dcefa mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XDelParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XDelParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XGroupParser.java index 0000000,5495270..5495270 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XGroupParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XGroupParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XSetIdParser.java index 0000000,2af95c3..2af95c3 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XSetIdParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XSetIdParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XTrimParser.java index 0000000,86a85b6..86a85b6 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XTrimParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XTrimParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZAddParser.java index 0000000,555aaf5..555aaf5 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZAddParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZAddParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZIncrByParser.java index 0000000,6bbf0d5..6bbf0d5 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZIncrByParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZIncrByParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZInterStoreParser.java index 0000000,9c8382e..9c8382e mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZInterStoreParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZInterStoreParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMaxParser.java index 0000000,d4b4ff0..d4b4ff0 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMaxParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMaxParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMinParser.java index 0000000,070d2da..070d2da mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMinParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMinParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemParser.java index 0000000,775a646..775a646 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByLexParser.java index 0000000,cbdaf91..cbdaf91 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByLexParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByLexParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByRankParser.java index 0000000,3827a41..3827a41 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByRankParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByRankParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByScoreParser.java index 0000000,8693382..8693382 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByScoreParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByScoreParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZUnionStoreParser.java index 0000000,04c0ef4..04c0ef4 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZUnionStoreParser.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZUnionStoreParser.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/Geo.java index 0000000,cf539db..cf539db mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/Geo.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/Geo.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java index 0000000,ff8cb29..ff8cb29 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEntry.java index 0000000,5cf2d86..5cf2d86 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEntry.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEntry.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java index 0000000,585df47..585df47 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java index 0000000,cde4367..cde4367 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisClosedListener.java index 0000000,8a47fd8..8a47fd8 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisClosedListener.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisClosedListener.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventListener.java index 0000000,57d5aa8..57d5aa8 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventListener.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventListener.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java index 0000000,bdab382..bdab382 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessorCallback.java index 0000000,c44f460..c44f460 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessorCallback.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessorCallback.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisExceptionListener.java index 0000000,bdbd139..bdbd139 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisExceptionListener.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisExceptionListener.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/ParseStringUtils.java index 0000000,b4714e5..b4714e5 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/ParseStringUtils.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/ParseStringUtils.java diff --cc connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/PropertyToObjectUtils.java index 0000000,62f09ce..62f09ce mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/PropertyToObjectUtils.java +++ b/connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/PropertyToObjectUtils.java diff --cc connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/ConfigTest.java index 0000000,e63f45f..e63f45f mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/ConfigTest.java +++ b/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/ConfigTest.java diff --cc connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/OptionsTest.java index 0000000,a7ac8ae..a7ac8ae mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/OptionsTest.java +++ b/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/OptionsTest.java diff --cc connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceConnectorTest.java index 0000000,355351b..355351b mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceConnectorTest.java +++ b/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceConnectorTest.java diff --cc connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceTaskTest.java index 0000000,4dd4397..4dd4397 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceTaskTest.java +++ b/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceTaskTest.java diff --cc connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisEntryConverterTest.java index 0000000,9b4d91c..9b4d91c mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisEntryConverterTest.java +++ b/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisEntryConverterTest.java diff --cc connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisPositionConverterTest.java index 0000000,03986d2..03986d2 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisPositionConverterTest.java +++ b/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisPositionConverterTest.java diff --cc connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/handler/RedisEventHandlerTest.java index 0000000,068187f..068187f mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/handler/RedisEventHandlerTest.java +++ b/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/handler/RedisEventHandlerTest.java diff --cc connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/parser/ParserTest.java index 0000000,b2b7960..b2b7960 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/parser/ParserTest.java +++ b/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/parser/ParserTest.java diff --cc connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/GeoTest.java index 0000000,c905140..c905140 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/GeoTest.java +++ b/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/GeoTest.java diff --cc connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/KVEntryTest.java index 0000000,65d8bcf..65d8bcf mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/KVEntryTest.java +++ b/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/KVEntryTest.java diff --cc connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/RedisEventTest.java index 0000000,a412e6d..a412e6d mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/RedisEventTest.java +++ b/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/RedisEventTest.java diff --cc connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ListenerTest.java index 0000000,6500eba..6500eba mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ListenerTest.java +++ b/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ListenerTest.java diff --cc connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ProcessorTest.java index 0000000,1410b2a..1410b2a mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ProcessorTest.java +++ b/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ProcessorTest.java diff --cc connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/ParseStringUtilsTest.java index 0000000,2a67959..2a67959 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/ParseStringUtilsTest.java +++ b/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/ParseStringUtilsTest.java diff --cc connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/PropertyToObjectUtilsTest.java index 0000000,ddcc59b..ddcc59b mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/PropertyToObjectUtilsTest.java +++ b/connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/PropertyToObjectUtilsTest.java diff --cc connector/rocketmq-connect-redis/style/copyright/Apache.xml index 0000000,e3e3dec..e3e3dec mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/style/copyright/Apache.xml +++ b/connector/rocketmq-connect-redis/style/copyright/Apache.xml diff --cc connector/rocketmq-connect-redis/style/copyright/profiles_settings.xml index 0000000,747c7e2..747c7e2 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/style/copyright/profiles_settings.xml +++ b/connector/rocketmq-connect-redis/style/copyright/profiles_settings.xml diff --cc connector/rocketmq-connect-redis/style/rmq_checkstyle.xml index 0000000,2872eb7..2872eb7 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/style/rmq_checkstyle.xml +++ b/connector/rocketmq-connect-redis/style/rmq_checkstyle.xml diff --cc connector/rocketmq-connect-redis/style/rmq_codeStyle.xml index 0000000,7c7ce54..7c7ce54 mode 000000,100644..100644 --- a/connector/rocketmq-connect-redis/style/rmq_codeStyle.xml +++ b/connector/rocketmq-connect-redis/style/rmq_codeStyle.xml
