public class JdbcInputFormat extends HiveInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>
HiveInputFormat.HiveInputSplit
mrwork, pathToPartitionInfo
Constructor and Description |
---|
JdbcInputFormat() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable> |
getRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.mapred.JobConf job,
org.apache.hadoop.mapred.Reporter reporter) |
org.apache.hadoop.mapred.InputSplit[] |
getSplits(org.apache.hadoop.mapred.JobConf job,
int numSplits) |
void |
setDbAccessor(DatabaseAccessor dbAccessor)
For testing purposes only
|
canWrapForLlap, configure, getInputFormatFromCache, getPartitionDescFromPath, init, pushFilters, pushProjectionsAndFilters, pushProjectionsAndFilters, wrapForLlap
public org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable> getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter) throws IOException
getRecordReader
in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>
getRecordReader
in class HiveInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>
IOException
public org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf job, int numSplits) throws IOException
getSplits
in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>
getSplits
in class HiveInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>
IOException
public void setDbAccessor(DatabaseAccessor dbAccessor)
dbAccessor
- DatabaseAccessor objectCopyright © 2021 The Apache Software Foundation. All rights reserved.