Review Board 1.7.22


SQOOP-846 Provide Netezza connector

Review Request #9543 - Created Feb. 21, 2013 and updated

Venkat Ranganathan
SQOOP-846
Reviewers
Sqoop
jarcec
sqoop-trunk
This addresses SQOOP-846 (provide a Netezza connector)
Ran all sqoop tests.   Ran Netezza manual tests against Netezza VMs version 6 and 7

Diff revision 5

This is not the most recent revision of the diff. The latest diff is revision 9. See what's changed.

1 2 3 4 5 6 7 8 9
1 2 3 4 5 6 7 8 9

  1. src/java/org/apache/sqoop/lib/DelimiterSet.java: Loading...
  2. src/java/org/apache/sqoop/manager/DefaultManagerFactory.java: Loading...
  3. src/java/org/apache/sqoop/manager/DirectNetezzaManager.java: Loading...
  4. src/java/org/apache/sqoop/manager/MySQLUtils.java: Loading...
  5. src/java/org/apache/sqoop/manager/NetezzaManager.java: Loading...
  6. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaDBDataSliceSplitter.java: Loading...
  7. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaDataDrivenDBInputFormat.java: Loading...
  8. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableExportJob.java: Loading...
  9. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableExportMapper.java: Loading...
  10. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableImportJob.java: Loading...
  11. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableImportMapper.java: Loading...
  12. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableInputFormat.java: Loading...
  13. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableInputSplitter.java: Loading...
  14. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableRecordExportMapper.java: Loading...
  15. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableTextExportMapper.java: Loading...
  16. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaJDBCStatementRunner.java: Loading...
  17. src/test/com/cloudera/sqoop/manager/DirectNetezzaExportManualTest.java: Loading...
  18. src/test/com/cloudera/sqoop/manager/NetezzaImportManualTest.java: Loading...
  19. src/test/com/cloudera/sqoop/manager/NetezzaTestUtils.java: Loading...
src/java/org/apache/sqoop/lib/DelimiterSet.java
Revision 4e9bcab New Change
[20] 30 lines
[+20] [+] public class DelimiterSet implements Cloneable {
31
  private char enclosedBy;
31
  private char enclosedBy;
32
  private char escapedBy;
32
  private char escapedBy;
33

    
   
33

   
34
  // If true, then the enclosed-by character is applied to every
34
  // If true, then the enclosed-by character is applied to every
35
  // field, not just ones containing embedded delimiters.
35
  // field, not just ones containing embedded delimiters.

    
   
36

   
36
  private boolean encloseRequired;
37
  private boolean encloseRequired;
37

    
   
38

   

    
   
39
  public static final String OUTPUT_FIELD_DELIM_KEY =

    
   
40
      "sqoop.output.field.delim";

    
   
41
  public static final String OUTPUT_RECORD_DELIM_KEY =

    
   
42
      "sqoop.output.record.delim";

    
   
43
  public static final String OUTPUT_ENCLOSED_BY_KEY =

    
   
44
      "sqoop.output.enclosed.by";

    
   
45
  public static final String OUTPUT_ESCAPED_BY_KEY =

    
   
46
      "sqoop.output.escaped.by";

    
   
47
  public static final String OUTPUT_ENCLOSE_REQUIRED_KEY =

    
   
48
      "sqoop.output.enclose.required";
38
  /**
49
  /**
39
   * Create a delimiter set with the default delimiters
50
   * Create a delimiter set with the default delimiters
40
   * (comma for fields, newline for records).
51
   * (comma for fields, newline for records).
41
   */
52
   */
42
  public DelimiterSet() {
53
  public DelimiterSet() {
[+20] [20] 175 lines
src/java/org/apache/sqoop/manager/DefaultManagerFactory.java
Revision 54eb258 New Change
 
src/java/org/apache/sqoop/manager/DirectNetezzaManager.java
New File
 
src/java/org/apache/sqoop/manager/MySQLUtils.java
Revision ef18818 New Change
 
src/java/org/apache/sqoop/manager/NetezzaManager.java
New File
 
src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaDBDataSliceSplitter.java
New File
 
src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaDataDrivenDBInputFormat.java
New File
 
src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableExportJob.java
New File
 
src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableExportMapper.java
New File
 
src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableImportJob.java
New File
 
src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableImportMapper.java
New File
 
src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableInputFormat.java
New File
 
src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableInputSplitter.java
New File
 
src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableRecordExportMapper.java
New File
 
src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableTextExportMapper.java
New File
 
src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaJDBCStatementRunner.java
New File
 
src/test/com/cloudera/sqoop/manager/DirectNetezzaExportManualTest.java
New File
 
src/test/com/cloudera/sqoop/manager/NetezzaImportManualTest.java
New File
 
src/test/com/cloudera/sqoop/manager/NetezzaTestUtils.java
New File
 
  1. src/java/org/apache/sqoop/lib/DelimiterSet.java: Loading...
  2. src/java/org/apache/sqoop/manager/DefaultManagerFactory.java: Loading...
  3. src/java/org/apache/sqoop/manager/DirectNetezzaManager.java: Loading...
  4. src/java/org/apache/sqoop/manager/MySQLUtils.java: Loading...
  5. src/java/org/apache/sqoop/manager/NetezzaManager.java: Loading...
  6. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaDBDataSliceSplitter.java: Loading...
  7. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaDataDrivenDBInputFormat.java: Loading...
  8. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableExportJob.java: Loading...
  9. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableExportMapper.java: Loading...
  10. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableImportJob.java: Loading...
  11. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableImportMapper.java: Loading...
  12. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableInputFormat.java: Loading...
  13. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableInputSplitter.java: Loading...
  14. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableRecordExportMapper.java: Loading...
  15. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaExternalTableTextExportMapper.java: Loading...
  16. src/java/org/apache/sqoop/mapreduce/db/netezza/NetezzaJDBCStatementRunner.java: Loading...
  17. src/test/com/cloudera/sqoop/manager/DirectNetezzaExportManualTest.java: Loading...
  18. src/test/com/cloudera/sqoop/manager/NetezzaImportManualTest.java: Loading...
  19. src/test/com/cloudera/sqoop/manager/NetezzaTestUtils.java: Loading...