----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/66475/ -----------------------------------------------------------
(Updated April 5, 2018, 12:35 p.m.) Review request for Sqoop, Boglarka Egyed, Fero Szabo, and Szabolcs Vasas. Bugs: SQOOP-3310 https://issues.apache.org/jira/browse/SQOOP-3310 Repository: sqoop-trunk Description ------- Adds the ability to import data from RDBMS to Apache Kafka Diffs ----- ivy.xml 6be4fa20fbbf1f303c69d86942b1874e18a14afc ivy/libraries.properties c44b50bc1361bb3a32f47ed2c1b9f291e8c18d05 src/java/org/apache/sqoop/SqoopOptions.java 651cebd69ee7e75d06c75945e3607c4fab7eb11c src/java/org/apache/sqoop/kafka/GenericRecordKafkaTransformer.java PRE-CREATION src/java/org/apache/sqoop/kafka/JsonKafkaTransformer.java PRE-CREATION src/java/org/apache/sqoop/kafka/KafkaProduceProcessor.java PRE-CREATION src/java/org/apache/sqoop/kafka/KafkaUtil.java PRE-CREATION src/java/org/apache/sqoop/kafka/ProducerRecordTransformer.java PRE-CREATION src/java/org/apache/sqoop/kafka/ProducerWrapper.java PRE-CREATION src/java/org/apache/sqoop/manager/SqlManager.java fe997c5f5186b027a7a91002b5544b69393973d0 src/java/org/apache/sqoop/mapreduce/DataDrivenImportJob.java a5962ba44282fc3ae48de23860de0992586e549a src/java/org/apache/sqoop/mapreduce/KafkaImportJob.java PRE-CREATION src/java/org/apache/sqoop/mapreduce/KafkaImportMapper.java PRE-CREATION src/java/org/apache/sqoop/tool/BaseSqoopTool.java b02e4fe7fda25c7f8171c7db17d15a7987459687 src/java/org/apache/sqoop/tool/ImportTool.java e9920058858653bec7407bf7992eb6445401e813 src/test/org/apache/sqoop/kafka/KafkaImportTest.java PRE-CREATION src/test/org/apache/sqoop/kafka/KafkaTestCase.java PRE-CREATION src/test/org/apache/sqoop/kafka/KafkaTestUtils.java PRE-CREATION src/test/org/apache/sqoop/kafka/TestGenericRecordKafkaTransformer.java PRE-CREATION src/test/org/apache/sqoop/kafka/TestJsonKafkaTransformer.java PRE-CREATION src/test/org/apache/sqoop/kafka/TestKafkaProduceProcessor.java PRE-CREATION src/test/org/apache/sqoop/kafka/TestKafkaUtil.java PRE-CREATION src/test/org/apache/sqoop/kafka/TestProducerWrapper.java PRE-CREATION Diff: https://reviews.apache.org/r/66475/diff/1/ Testing ------- Ran unit and 3rd party tests successfully Thanks, Andras Beni