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 92c14dac [ISSUE #411] Check taskConfigs (#412)
add 009acb3b [ISSUE #408] Add apache hive source connector (#410)
No new revisions were added by this update.
Summary of changes:
connectors/rocketmq-connect-hive/README.md | 34 +++++
.../pom.xml | 127 +++++++++----------
.../rocketmq/connect/hive/config/HiveColumn.java | 65 ++++++++++
.../rocketmq/connect/hive/config/HiveConfig.java} | 82 ++++++------
.../connect/hive/config/HiveConstant.java} | 30 +++--
.../connect/hive/config/HiveJdbcDriverManager.java | 72 +++++++++++
.../rocketmq/connect/hive/config/HiveRecord.java} | 25 +++-
.../connect/hive/config/SchemaManger.java} | 36 +++---
.../hive/connector/HiveSourceConnector.java | 110 ++++++++++++++++
.../connect/hive/connector/HiveSourceTask.java | 138 +++++++++++++++++++++
.../connect/hive/replicator/source/HiveQuery.java | 119 ++++++++++++++++++
.../hive/replicator/source/HiveReplicator.java} | 33 ++---
.../connect/hive/config/HiveConfigTest.java} | 18 +--
.../hive/config/HiveJdbcDriverManagerTest.java | 25 ++--
.../hive/connector/HiveSourceConnectorTest.java | 65 ++++++++++
.../connect/hive/connector/HiveSourceTaskTest.java | 104 ++++++++++++++++
.../hive/replicator/source/HiveQueryTest.java | 56 +++++++++
17 files changed, 960 insertions(+), 179 deletions(-)
create mode 100644 connectors/rocketmq-connect-hive/README.md
copy connectors/{rocketmq-connect-elasticsearch =>
rocketmq-connect-hive}/pom.xml (94%)
create mode 100644
connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveColumn.java
copy
connectors/{rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/config/ElasticsearchConfig.java
=>
rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveConfig.java}
(68%)
copy
connectors/{rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/config/ElasticsearchConstant.java
=>
rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveConstant.java}
(51%)
create mode 100644
connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveJdbcDriverManager.java
copy
connectors/{rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/KVEntryConverter.java
=>
rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveRecord.java}
(64%)
copy
connectors/{rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/TimeColumnParser.java
=>
rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/SchemaManger.java}
(52%)
create mode 100644
connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/connector/HiveSourceConnector.java
create mode 100644
connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/connector/HiveSourceTask.java
create mode 100644
connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/replicator/source/HiveQuery.java
copy
connectors/{rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/replicator/source/ElasticsearchReplicator.java
=>
rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/replicator/source/HiveReplicator.java}
(63%)
copy
connectors/{rocketmq-connect-cassandra/src/test/java/org/apache/rocketmq/connect/cassandra/config/ConfigUtilTest.java
=>
rocketmq-connect-hive/src/test/java/org/apache/rocketmq/connect/hive/config/HiveConfigTest.java}
(72%)
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/errors/ProcessingContextTest.java
=>
connectors/rocketmq-connect-hive/src/test/java/org/apache/rocketmq/connect/hive/config/HiveJdbcDriverManagerTest.java
(64%)
create mode 100644
connectors/rocketmq-connect-hive/src/test/java/org/apache/rocketmq/connect/hive/connector/HiveSourceConnectorTest.java
create mode 100644
connectors/rocketmq-connect-hive/src/test/java/org/apache/rocketmq/connect/hive/connector/HiveSourceTaskTest.java
create mode 100644
connectors/rocketmq-connect-hive/src/test/java/org/apache/rocketmq/connect/hive/replicator/source/HiveQueryTest.java
