----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35591/ -----------------------------------------------------------
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 ----- 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/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/KafkaLoader.java ad9ec34755e36985078e880a0a076c46337ef411 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/KafkaUtils.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 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
