This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git.
from 5feab9c Add 'connector/rocketmq-connect-rabbitmq/' from commit
'a7ab1c46a9938df2984c3ad730609c1a7797cc9b'
new 8862e3e Init rocketmq-connect-redis
new 14da1d8 Add Redis connector. (#403)
new 1290dde Support redis 6 (#510)
new 18f2061 bump up the connect version to 0.1.1
new ed629ae update rocketmq-connect-redis dependency (#583)
new 8a07d71 Update rocketmq-connect-redis pom.xml (#592)
new 4fdd8b2 Fix exception parsing redis command "set a 1010 px 1000"
(#862)
new ce39378 Add 'connector/rocketmq-connect-redis/' from commit
'4fdd8b2e20c4d815e7bd5c9cef13be89fcd56c02'
The 8 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:
connector/rocketmq-connect-redis/README-CN.md | 19 +
connector/rocketmq-connect-redis/README.md | 19 +
.../pom.xml | 149 +--
.../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} | 36 +-
.../redis/connector/RedisSourceConnector.java | 42 +-
.../connect/redis/connector/RedisSourceTask.java | 148 +++
.../connect/redis/converter/KVEntryConverter.java} | 11 +-
.../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 | 29 +-
.../connect/redis/parser/BitFieldParser.java | 31 +-
.../rocketmq/connect/redis/parser/BitOpParser.java | 34 +-
.../connect/redis/parser/BrPopLPushParser.java | 34 +-
.../connect/redis/parser/CommonParser.java | 117 +++
.../connect/redis/parser/DecrByParser.java | 31 +-
.../rocketmq/connect/redis/parser/DecrParser.java} | 22 +-
.../redis/parser/DefaultRedisRdbParser.java | 197 ++++
.../rocketmq/connect/redis/parser/DelParser.java | 39 +-
.../rocketmq/connect/redis/parser/EvalParser.java | 29 +-
.../connect/redis/parser/EvalShaParser.java | 29 +-
.../rocketmq/connect/redis/parser/ExecParser.java} | 22 +-
.../connect/redis/parser/ExpireAtParser.java | 31 +-
.../connect/redis/parser/ExpireParser.java | 33 +-
.../connect/redis/parser/FlushAllParser.java | 31 +-
.../connect/redis/parser/FlushDbParser.java | 30 +-
.../connect/redis/parser/GeoAddParser.java | 49 +
.../connect/redis/parser/GetsetParser.java | 30 +-
.../rocketmq/connect/redis/parser/HDelParser.java | 34 +-
.../connect/redis/parser/HIncrByParser.java | 34 +-
.../connect/redis/parser/HSetNxParser.java | 30 +-
.../rocketmq/connect/redis/parser/HSetParser.java | 30 +-
.../rocketmq/connect/redis/parser/HmSetParser.java | 30 +-
.../connect/redis/parser/IncrByParser.java | 31 +-
.../rocketmq/connect/redis/parser/IncrParser.java} | 22 +-
.../rocketmq/connect/redis/parser/LPopParser.java} | 22 +-
.../rocketmq/connect/redis/parser/LPushParser.java | 34 +-
.../connect/redis/parser/LPushXParser.java | 30 +-
.../rocketmq/connect/redis/parser/LRemParser.java | 34 +-
.../rocketmq/connect/redis/parser/LSetParser.java | 34 +-
.../rocketmq/connect/redis/parser/LTrimParser.java | 34 +-
.../connect/redis/parser/LinsertParser.java | 51 +
.../connect/redis/parser/MSetNxParser.java | 30 +-
.../rocketmq/connect/redis/parser/MSetParser.java | 30 +-
.../rocketmq/connect/redis/parser/MoveParser.java | 31 +-
.../connect/redis/parser/MultiParser.java} | 22 +-
.../connect/redis/parser/PExpireAtParser.java | 31 +-
.../connect/redis/parser/PExpireParser.java | 31 +-
.../connect/redis/parser/PSetExParser.java | 34 +-
.../rocketmq/connect/redis/parser/Parser.java} | 9 +-
.../connect/redis/parser/PersistParser.java | 31 +-
.../rocketmq/connect/redis/parser/PfAddParser.java | 34 +-
.../connect/redis/parser/PfCountParser.java | 30 +-
.../connect/redis/parser/PfMergeParser.java | 34 +-
.../connect/redis/parser/PublishParser.java | 30 +-
.../connect/redis/parser/RPopLPushParser.java | 30 +-
.../rocketmq/connect/redis/parser/RPopParser.java} | 22 +-
.../rocketmq/connect/redis/parser/RPushParser.java | 34 +-
.../connect/redis/parser/RPushXParser.java | 30 +-
.../connect/redis/parser/RedisRdbParser.java | 67 ++
.../connect/redis/parser/RenameNxParser.java | 30 +-
.../connect/redis/parser/RenameParser.java | 30 +-
.../connect/redis/parser/RestoreParser.java} | 47 +-
.../rocketmq/connect/redis/parser/SAddParser.java | 34 +-
.../connect/redis/parser/SDiffStoreParser.java | 34 +-
.../connect/redis/parser/SInterStoreParser.java | 34 +-
.../rocketmq/connect/redis/parser/SMoveParser.java | 34 +-
.../rocketmq/connect/redis/parser/SRemParser.java | 34 +-
.../connect/redis/parser/SUnionStoreParser.java | 34 +-
.../connect/redis/parser/ScriptParser.java} | 22 +-
.../connect/redis/parser/SelectParser.java | 31 +-
.../connect/redis/parser/SetBitParser.java | 34 +-
.../rocketmq/connect/redis/parser/SetExParser.java | 35 +-
.../rocketmq/connect/redis/parser/SetNxParser.java | 30 +-
.../rocketmq/connect/redis/parser/SetParser.java | 59 ++
.../connect/redis/parser/SetRangeParser.java | 34 +-
.../rocketmq/connect/redis/parser/SortParser.java | 31 +-
.../connect/redis/parser/SwapDbParser.java | 31 +-
.../connect/redis/parser/UnLinkParser.java | 30 +-
.../rocketmq/connect/redis/parser/XAckParser.java | 49 +
.../rocketmq/connect/redis/parser/XAddParser.java | 39 +-
.../connect/redis/parser/XClaimParser.java | 88 ++
.../rocketmq/connect/redis/parser/XDelParser.java | 34 +-
.../connect/redis/parser/XGroupParser.java | 31 +-
.../connect/redis/parser/XSetIdParser.java | 30 +-
.../rocketmq/connect/redis/parser/XTrimParser.java | 36 +-
.../rocketmq/connect/redis/parser/ZAddParser.java | 69 ++
.../connect/redis/parser/ZIncrByParser.java | 34 +-
.../connect/redis/parser/ZInterStoreParser.java | 30 +-
.../connect/redis/parser/ZPopMaxParser.java | 31 +-
.../connect/redis/parser/ZPopMinParser.java | 31 +-
.../rocketmq/connect/redis/parser/ZRemParser.java | 34 +-
.../connect/redis/parser/ZRemRangeByLexParser.java | 34 +-
.../redis/parser/ZRemRangeByRankParser.java | 34 +-
.../redis/parser/ZRemRangeByScoreParser.java | 34 +-
.../connect/redis/parser/ZUnionStoreParser.java | 30 +-
.../apache/rocketmq/connect/redis/pojo/Geo.java | 37 +-
.../rocketmq/connect/redis/pojo/KVEntry.java | 71 ++
.../rocketmq/connect/redis/pojo/RedisEntry.java | 171 +++
.../rocketmq/connect/redis/pojo/RedisEvent.java | 42 +-
.../processor/DefaultRedisEventProcessor.java | 453 ++++++++
.../redis/processor/RedisClosedListener.java} | 24 +-
.../redis/processor/RedisEventListener.java | 121 +++
.../redis/processor/RedisEventProcessor.java | 33 +-
.../processor/RedisEventProcessorCallback.java} | 8 +-
.../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 | 4 +-
.../style/rmq_checkstyle.xml | 1 -
.../style}/rmq_codeStyle.xml | 2 +-
132 files changed, 6664 insertions(+), 1678 deletions(-)
create mode 100644 connector/rocketmq-connect-redis/README-CN.md
create mode 100644 connector/rocketmq-connect-redis/README.md
copy connector/{rocketmq-connect-kafka => rocketmq-connect-redis}/pom.xml (70%)
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Options.java
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/RedisConstants.java
copy
connector/{rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/DefaultColumnParser.java
=>
rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/SyncMod.java}
(60%)
copy
rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceConnector.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java
(67%)
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceTask.java
copy
connector/{rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/ITaskDivideStrategy.java
=>
rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/KVEntryConverter.java}
(75%)
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisEntryConverter.java
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisPositionConverter.java
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/DefaultRedisEventHandler.java
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/RedisEventHandler.java
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AbstractCommandParser.java
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java
(63%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitFieldParser.java
(63%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitOpParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BrPopLPushParser.java
(55%)
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/CommonParser.java
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrByParser.java
(59%)
copy
connector/{rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BooleanColumnParser.java
=>
rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrParser.java}
(68%)
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DefaultRedisRdbParser.java
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DelParser.java
(53%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalParser.java
(61%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalShaParser.java
(61%)
copy
connector/{rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BooleanColumnParser.java
=>
rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExecParser.java}
(68%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireAtParser.java
(58%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireParser.java
(54%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushAllParser.java
(68%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushDbParser.java
(68%)
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GeoAddParser.java
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GetsetParser.java
(63%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HDelParser.java
(57%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HIncrByParser.java
(55%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetNxParser.java
(62%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetParser.java
(62%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HmSetParser.java
(61%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrByParser.java
(59%)
copy
connector/{rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BooleanColumnParser.java
=>
rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrParser.java}
(68%)
copy
connector/{rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BooleanColumnParser.java
=>
rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPopParser.java}
(68%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushXParser.java
(63%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LRemParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LSetParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LTrimParser.java
(57%)
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LinsertParser.java
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetNxParser.java
(61%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetParser.java
(62%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MoveParser.java
(59%)
copy
connector/{rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BooleanColumnParser.java
=>
rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MultiParser.java}
(68%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireAtParser.java
(58%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireParser.java
(59%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PSetExParser.java
(56%)
copy
connector/{rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideStrategyEnum.java
=>
rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/Parser.java}
(83%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PersistParser.java
(68%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfAddParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfCountParser.java
(62%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfMergeParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PublishParser.java
(63%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopLPushParser.java
(62%)
copy
connector/{rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BooleanColumnParser.java
=>
rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopParser.java}
(68%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushXParser.java
(63%)
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RedisRdbParser.java
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameNxParser.java
(63%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameParser.java
(63%)
copy
connector/{rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/SetColumnParser.java
=>
rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RestoreParser.java}
(50%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SAddParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SDiffStoreParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SInterStoreParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SMoveParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SRemParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SUnionStoreParser.java
(56%)
copy
connector/{rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BooleanColumnParser.java
=>
rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ScriptParser.java}
(68%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SelectParser.java
(59%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetBitParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetExParser.java
(55%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetNxParser.java
(64%)
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetRangeParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SortParser.java
(63%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SwapDbParser.java
(63%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/UnLinkParser.java
(62%)
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAckParser.java
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAddParser.java
(50%)
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XClaimParser.java
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XDelParser.java
(57%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XGroupParser.java
(62%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XSetIdParser.java
(63%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XTrimParser.java
(52%)
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZAddParser.java
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZIncrByParser.java
(55%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZInterStoreParser.java
(59%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMaxParser.java
(59%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMinParser.java
(59%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByLexParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByRankParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByScoreParser.java
(56%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZUnionStoreParser.java
(59%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/Geo.java
(59%)
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEntry.java
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java
(51%)
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java
copy
connector/{rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/TaskTopicInfo.java
=>
rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisClosedListener.java}
(57%)
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventListener.java
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java
(55%)
copy
connector/{rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideStrategyEnum.java
=>
rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessorCallback.java}
(83%)
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisExceptionListener.java
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/ParseStringUtils.java
create mode 100644
connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/PropertyToObjectUtils.java
create mode 100644
connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/ConfigTest.java
create mode 100644
connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/OptionsTest.java
create mode 100644
connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceConnectorTest.java
create mode 100644
connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceTaskTest.java
create mode 100644
connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisEntryConverterTest.java
create mode 100644
connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisPositionConverterTest.java
create mode 100644
connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/handler/RedisEventHandlerTest.java
create mode 100644
connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/parser/ParserTest.java
create mode 100644
connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/GeoTest.java
create mode 100644
connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/KVEntryTest.java
create mode 100644
connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/RedisEventTest.java
create mode 100644
connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ListenerTest.java
create mode 100644
connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ProcessorTest.java
create mode 100644
connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/ParseStringUtilsTest.java
create mode 100644
connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/PropertyToObjectUtilsTest.java
create mode 100644 connector/rocketmq-connect-redis/style/copyright/Apache.xml
copy {style =>
connector/rocketmq-connect-redis/style}/copyright/profiles_settings.xml (95%)
copy connector/{rocketmq-connect-hudi =>
rocketmq-connect-redis}/style/rmq_checkstyle.xml (99%)
copy {style => connector/rocketmq-connect-redis/style}/rmq_codeStyle.xml (99%)
