|
@@ -21,9 +21,6 @@ package org.apache.hadoop.mapreduce.lib.db;
|
|
import java.io.DataInput;
|
|
import java.io.DataInput;
|
|
import java.io.DataOutput;
|
|
import java.io.DataOutput;
|
|
import java.io.IOException;
|
|
import java.io.IOException;
|
|
-import java.sql.Connection;
|
|
|
|
-import java.sql.DatabaseMetaData;
|
|
|
|
-import java.sql.PreparedStatement;
|
|
|
|
import java.sql.ResultSet;
|
|
import java.sql.ResultSet;
|
|
import java.sql.SQLException;
|
|
import java.sql.SQLException;
|
|
import java.sql.Statement;
|
|
import java.sql.Statement;
|
|
@@ -36,15 +33,11 @@ import org.slf4j.LoggerFactory;
|
|
|
|
|
|
import org.apache.hadoop.io.LongWritable;
|
|
import org.apache.hadoop.io.LongWritable;
|
|
import org.apache.hadoop.io.Text;
|
|
import org.apache.hadoop.io.Text;
|
|
-import org.apache.hadoop.io.Writable;
|
|
|
|
-import org.apache.hadoop.mapreduce.InputFormat;
|
|
|
|
import org.apache.hadoop.mapreduce.InputSplit;
|
|
import org.apache.hadoop.mapreduce.InputSplit;
|
|
import org.apache.hadoop.mapreduce.Job;
|
|
import org.apache.hadoop.mapreduce.Job;
|
|
import org.apache.hadoop.mapreduce.JobContext;
|
|
import org.apache.hadoop.mapreduce.JobContext;
|
|
import org.apache.hadoop.mapreduce.MRJobConfig;
|
|
import org.apache.hadoop.mapreduce.MRJobConfig;
|
|
import org.apache.hadoop.mapreduce.RecordReader;
|
|
import org.apache.hadoop.mapreduce.RecordReader;
|
|
-import org.apache.hadoop.mapreduce.TaskAttemptContext;
|
|
|
|
-import org.apache.hadoop.util.ReflectionUtils;
|
|
|
|
import org.apache.hadoop.classification.InterfaceAudience;
|
|
import org.apache.hadoop.classification.InterfaceAudience;
|
|
import org.apache.hadoop.classification.InterfaceStability;
|
|
import org.apache.hadoop.classification.InterfaceStability;
|
|
import org.apache.hadoop.conf.Configurable;
|
|
import org.apache.hadoop.conf.Configurable;
|