diff --git a/src/java/com/cloudera/sqoop/manager/ExportJobContext.java b/src/java/com/cloudera/sqoop/manager/ExportJobContext.java index 552f346a..cad63a16 100644 --- a/src/java/com/cloudera/sqoop/manager/ExportJobContext.java +++ b/src/java/com/cloudera/sqoop/manager/ExportJobContext.java @@ -31,6 +31,10 @@ public ExportJobContext(final String table, final String jar, super(table, jar, opts); } + public void setConnManager(ConnManager mgr) { + super.setConnManager(mgr); + } + public ConnManager getConnManager() { return (ConnManager)super.getConnManager(); } diff --git a/src/java/com/cloudera/sqoop/mapreduce/ExportOutputFormat.java b/src/java/com/cloudera/sqoop/mapreduce/ExportOutputFormat.java index dba4a496..48c352b9 100644 --- a/src/java/com/cloudera/sqoop/mapreduce/ExportOutputFormat.java +++ b/src/java/com/cloudera/sqoop/mapreduce/ExportOutputFormat.java @@ -19,10 +19,23 @@ package com.cloudera.sqoop.mapreduce; import com.cloudera.sqoop.lib.SqoopRecord; +import org.apache.hadoop.mapreduce.TaskAttemptContext; + +import java.sql.SQLException; /** * @deprecated Moving to use org.apache.sqoop namespace. */ public class ExportOutputFormat extends org.apache.sqoop.mapreduce.ExportOutputFormat { + + /** {@inheritDoc}. **/ + public class ExportRecordWriter extends + org.apache.sqoop.mapreduce.ExportOutputFormat.ExportRecordWriter { + + public ExportRecordWriter(TaskAttemptContext context) + throws ClassNotFoundException, SQLException { + super(context); + } + } }