sqoop-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andras Beni via Review Board <nore...@reviews.apache.org>
Subject Review Request 66475: SQOOP-3310 Add import to Kafka feature
Date Thu, 05 Apr 2018 12:33:39 GMT

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

Review request for Sqoop, Boglarka Egyed, Fero Szabo, and Szabolcs Vasas.


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


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