sqoop-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "richard zhou" <richard.z...@intel.com>
Subject Re: Review Request 35591: Sqoop-1853: Kafka connector supporting FROM direction
Date Tue, 04 Aug 2015 08:25:51 GMT

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/35591/
-----------------------------------------------------------

(Updated Aug. 4, 2015, 8:25 a.m.)


Review request for Sqoop.


Repository: sqoop-sqoop2


Description
-------

This is an initial patch. It may not work currently. Please check whether this design of framework
is fine or not.


Diffs (updated)
-----

  common/src/main/java/org/apache/sqoop/error/code/KafkaConnectorErrors.java 436b852b0c69258753d7f09c3411bc19d16957a3

  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/KafkaConnector.java
e3eafe87f7376031d79fec76739fd9e648df872b 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/KafkaConstants.java
9d3877db4ab53b09aec34511be6a29cc28611f63 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/KafkaExtractor.java
PRE-CREATION 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/KafkaFromDestroyer.java
PRE-CREATION 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/KafkaFromInitializer.java
PRE-CREATION 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/KafkaPartition.java
PRE-CREATION 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/KafkaPartitioner.java
PRE-CREATION 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/configuration/FromJobConfig.java
PRE-CREATION 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/configuration/FromJobConfiguration.java
PRE-CREATION 
  connector/connector-kafka/src/main/resources/kafka-connector-config.properties d3e1e6f3f0de8bae60ac22bbf718dddd8330362a


Diff: https://reviews.apache.org/r/35591/diff/


Testing
-------

Passed compile, but it still needs to be tested in the real cluster.


Thanks,

richard zhou


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message