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 ec58cc3c [ISSUE #340] Fix failed unit test (#343)
add 5ff223f5 [ISSUE #317]cassandra sourceConnector and sinkConnector adapt
to new api (#318)
No new revisions were added by this update.
Summary of changes:
connectors/rocketmq-connect-cassandra/README.md | 46 ++++++-
connectors/rocketmq-connect-cassandra/pom.xml | 12 +-
.../connect/cassandra/common/ConstDefine.java | 7 +
.../rocketmq/connect/cassandra/common/DBUtils.java | 36 ++---
.../rocketmq/connect/cassandra/common/Utils.java | 1 -
.../rocketmq/connect/cassandra/config/Config.java | 10 +-
.../connect/cassandra/config/ConfigUtil.java | 1 -
.../cassandra/config/DbConnectorConfig.java | 1 -
.../cassandra/config/SinkDbConnectorConfig.java | 8 +-
.../cassandra/config/SourceDbConnectorConfig.java | 15 +--
.../connect/cassandra/config/TaskTopicInfo.java | 2 -
.../connector/CassandraSinkConnector.java | 73 +++++-----
.../cassandra/connector/CassandraSinkTask.java | 67 ++-------
.../connector/CassandraSourceConnector.java | 57 +++-----
.../cassandra/connector/CassandraSourceTask.java | 149 +++++++++++++--------
.../connect/cassandra/schema/Database.java | 9 +-
.../rocketmq/connect/cassandra/schema/Schema.java | 24 +---
.../schema/column/BooleanColumnParser.java | 2 +-
.../cassandra/schema/column/ColumnParser.java | 4 +-
.../rocketmq/connect/cassandra/sink/Updater.java | 95 ++++++-------
.../rocketmq/connect/cassandra/source/Querier.java | 53 +++++---
.../cassandra/strategy/DivideTaskByTopic.java | 65 +++++----
.../cassandra/strategy/TaskDivideStrategy.java | 6 +-
.../connect/cassandra/common/CloneUtilsTest.java} | 19 ++-
.../connect/cassandra/common/DBUtilsTest.java | 23 ++--
.../connect/cassandra/common/TestClone.java} | 18 ++-
.../connect/cassandra/common/UtilsTest.java | 77 +++++++++++
.../connect/cassandra/config/ConfigUtilTest.java | 22 +--
.../connector/CassandraSinkConnectorTest.java | 65 +++++++++
.../cassandra/connector/CassandraSinkTaskTest.java | 29 ++--
.../connector/CassandraSourceConnectorTest.java | 69 ++++++++++
31 files changed, 654 insertions(+), 411 deletions(-)
copy
connectors/rocketmq-connect-cassandra/src/{main/java/org/apache/rocketmq/connect/cassandra/common/DataType.java
=> test/java/org/apache/rocketmq/connect/cassandra/common/CloneUtilsTest.java}
(73%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/Base64UtilTest.java
=>
connectors/rocketmq-connect-cassandra/src/test/java/org/apache/rocketmq/connect/cassandra/common/DBUtilsTest.java
(59%)
copy
connectors/rocketmq-connect-cassandra/src/{main/java/org/apache/rocketmq/connect/cassandra/common/ConstDefine.java
=> test/java/org/apache/rocketmq/connect/cassandra/common/TestClone.java} (74%)
create mode 100644
connectors/rocketmq-connect-cassandra/src/test/java/org/apache/rocketmq/connect/cassandra/common/UtilsTest.java
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/Base64UtilTest.java
=>
connectors/rocketmq-connect-cassandra/src/test/java/org/apache/rocketmq/connect/cassandra/config/ConfigUtilTest.java
(61%)
create mode 100644
connectors/rocketmq-connect-cassandra/src/test/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkConnectorTest.java
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/record/ConverterConfigTest.java
=>
connectors/rocketmq-connect-cassandra/src/test/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkTaskTest.java
(54%)
create mode 100644
connectors/rocketmq-connect-cassandra/src/test/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceConnectorTest.java
