github/sqoop
5
0
Fork 0
mirror of https://github.com/apache/sqoop.git synced 2025-05-04 03:41:08 +08:00
Code Issues Projects Releases Wiki Activity

SQOOP-1118: Move PostgreSQL specific MR codes to org.apache.sqoop.mapreduce.posgresql

Browse Source 
(Masatake Iwasaki via Jarek Jarcec Cecho)
This commit is contained in:
Jarek Jarcec Cecho 2013-07-09 19:45:32 -07:00
parent fb29b8f9fc
commit b8fd602028
4 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/java/org/apache/sqoop/manager/PGBulkloadManager.java
View File

@ -26,7 +26,7 @@
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.apache.sqoop.mapreduce.ExportInputFormat; import org.apache.sqoop.mapreduce.ExportInputFormat;
import org.apache.sqoop.mapreduce.PGBulkloadExportJob; import org.apache.sqoop.mapreduce.postgresql.PGBulkloadExportJob;

3
src/java/org/apache/sqoop/mapreduce/PGBulkloadExportJob.java → src/java/org/apache/sqoop/mapreduce/postgresql/PGBulkloadExportJob.java
View File

@ -16,7 +16,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.apache.sqoop.mapreduce; package org.apache.sqoop.mapreduce.postgresql;
import java.io.IOException; import java.io.IOException;
import com.cloudera.sqoop.manager.ExportJobContext; import com.cloudera.sqoop.manager.ExportJobContext;
@ -35,6 +35,7 @@
import org.apache.sqoop.config.ConfigurationHelper; import org.apache.sqoop.config.ConfigurationHelper;
import org.apache.sqoop.lib.DelimiterSet; import org.apache.sqoop.lib.DelimiterSet;
import org.apache.sqoop.manager.ConnManager; import org.apache.sqoop.manager.ConnManager;
import org.apache.sqoop.mapreduce.ExportJobBase;
import org.apache.sqoop.mapreduce.db.DBConfiguration; import org.apache.sqoop.mapreduce.db.DBConfiguration;
import org.apache.sqoop.orm.TableClassName; import org.apache.sqoop.orm.TableClassName;

3
src/java/org/apache/sqoop/mapreduce/PGBulkloadExportMapper.java → src/java/org/apache/sqoop/mapreduce/postgresql/PGBulkloadExportMapper.java
View File

@ -16,7 +16,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.apache.sqoop.mapreduce; package org.apache.sqoop.mapreduce.postgresql;
import java.io.BufferedReader; import java.io.BufferedReader;
import java.io.BufferedWriter; import java.io.BufferedWriter;
@ -37,6 +37,7 @@
import org.apache.hadoop.io.Writable; import org.apache.hadoop.io.Writable;
import org.apache.sqoop.lib.SqoopRecord; import org.apache.sqoop.lib.SqoopRecord;
import org.apache.hadoop.mapreduce.Mapper.Context; import org.apache.hadoop.mapreduce.Mapper.Context;
import org.apache.sqoop.mapreduce.AutoProgressMapper;
import org.apache.sqoop.mapreduce.db.DBConfiguration; import org.apache.sqoop.mapreduce.db.DBConfiguration;
import org.apache.sqoop.util.LoggingUtils; import org.apache.sqoop.util.LoggingUtils;
import org.apache.sqoop.util.PostgreSQLUtils; import org.apache.sqoop.util.PostgreSQLUtils;

3
src/java/org/apache/sqoop/mapreduce/PGBulkloadExportReducer.java → src/java/org/apache/sqoop/mapreduce/postgresql/PGBulkloadExportReducer.java
View File

@ -16,7 +16,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.apache.sqoop.mapreduce; package org.apache.sqoop.mapreduce.postgresql;
import java.io.IOException; import java.io.IOException;
import java.sql.Connection; import java.sql.Connection;
@ -28,6 +28,7 @@
import org.apache.hadoop.io.LongWritable; import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.NullWritable; import org.apache.hadoop.io.NullWritable;
import org.apache.hadoop.io.Text; import org.apache.hadoop.io.Text;
import org.apache.sqoop.mapreduce.AutoProgressReducer;
import org.apache.sqoop.mapreduce.db.DBConfiguration; import org.apache.sqoop.mapreduce.db.DBConfiguration;
import org.apache.sqoop.util.LoggingUtils; import org.apache.sqoop.util.LoggingUtils;