org.apache.hive.storage.jdbc

Class JdbcInputFormat

java.lang.Object

org.apache.hadoop.hive.ql.io.HiveInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>

org.apache.hive.storage.jdbc.JdbcInputFormat

All Implemented Interfaces:

org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>, org.apache.hadoop.mapred.JobConfigurable

public class JdbcInputFormat
extends HiveInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.io.HiveInputFormat

HiveInputFormat.HiveInputSplit, HiveInputFormat.HiveInputSplitComparator

Field Summary

Fields inherited from class org.apache.hadoop.hive.ql.io.HiveInputFormat

mrwork, pathToPartitionInfo

Constructor Summary

Constructors

Constructor and Description
JdbcInputFormat()

Method Summary

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

Methods inherited from class org.apache.hadoop.hive.ql.io.HiveInputFormat

canInjectCaches, canWrapForLlap, configure, createConfForMmOriginalsSplit, getInputFormatFromCache, getMmValidWriteIds, getPartitionDescFromPath, init, injectLlapCaches, processPathsForMmRead, pushFilters, pushProjectionsAndFilters, pushProjectionsAndFilters, wrapForLlap

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JdbcInputFormat

public JdbcInputFormat()

Method Detail

getRecordReader

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

Specified by:

getRecordReader in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>

Overrides:

getRecordReader in class HiveInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>

Throws:

IOException

getSplits

public org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf job,
                                                       int numSplits)
                                                throws IOException

Specified by:

getSplits in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>

Overrides:

getSplits in class HiveInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>

Throws:

IOException

setDbAccessor

public void setDbAccessor(DatabaseAccessor dbAccessor)

For testing purposes only

Parameters:

dbAccessor - DatabaseAccessor object