Review Board 1.7.22


SQOOP-974 Support for stage table

Review Request #14022 - Created Sept. 7, 2013 and submitted

Raghav Gautam
sqoop-974
Reviewers
Sqoop
sqoop-sqoop2
This patch adds support for stage table to Sqoop2.
Unit tests as well as integration tests have been added.
All the tests pass.
Feature was manually tested.
connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcConnectorError.java
Revision 671bb4a New Change
[20] 70 lines
[+20]
71
  GENERIC_JDBC_CONNECTOR_0015("Partition column contains unsupported values"),
71
  GENERIC_JDBC_CONNECTOR_0015("Partition column contains unsupported values"),
72

    
   
72

   
73
  /** Can't fetch schema */
73
  /** Can't fetch schema */
74
  GENERIC_JDBC_CONNECTOR_0016("Can't fetch schema"),
74
  GENERIC_JDBC_CONNECTOR_0016("Can't fetch schema"),
75

    
   
75

   

    
   
76
  /** Neither the table name nor the table sql are specified. */

    
   
77
  GENERIC_JDBC_CONNECTOR_0017("The stage table is not empty."),

    
   
78

   

    
   
79
  GENERIC_JDBC_CONNECTOR_0018("Error occurred while transferring data from " +

    
   
80
    "stage table to destination table."),
76
  ;
81
  ;
77

    
   
82

   
78
  private final String message;
83
  private final String message;
79

    
   
84

   
80
  private GenericJdbcConnectorError(String message) {
85
  private GenericJdbcConnectorError(String message) {
[+20] [20] 11 lines
connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcExecutor.java
Revision 75cf9d9 New Change
 
connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcExportDestroyer.java
Revision 588e236 New Change
 
connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcExportInitializer.java
Revision 7212843 New Change
 
connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcValidator.java
Revision 4e24517 New Change
 
connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/configuration/ExportTableForm.java
Revision a311c06 New Change
 
connector/connector-generic-jdbc/src/main/resources/generic-jdbc-connector-resources.properties
Revision 0950e32 New Change
 
connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/GenericJdbcExecutorTest.java
New File
 
connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestExportInitializer.java
Revision f83aaa2 New Change
 
test/src/test/java/org/apache/sqoop/integration/connector/jdbc/generic/exports/TableStagedExportTest.java
New File
 
  1. connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcConnectorError.java: Loading...
  2. connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcExecutor.java: Loading...
  3. connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcExportDestroyer.java: Loading...
  4. connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcExportInitializer.java: Loading...
  5. connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcValidator.java: Loading...
  6. connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/configuration/ExportTableForm.java: Loading...
  7. connector/connector-generic-jdbc/src/main/resources/generic-jdbc-connector-resources.properties: Loading...
  8. connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/GenericJdbcExecutorTest.java: Loading...
  9. connector/connector-generic-jdbc/src/test/java/org/apache/sqoop/connector/jdbc/TestExportInitializer.java: Loading...
  10. test/src/test/java/org/apache/sqoop/integration/connector/jdbc/generic/exports/TableStagedExportTest.java: Loading...