org.apache.hive.storage.jdbc

Class JdbcRecordReader

java.lang.Object

org.apache.hive.storage.jdbc.JdbcRecordReader

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>

public class JdbcRecordReader
extends Object
implements org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>

Constructor Summary

Constructors

Constructor and Description
JdbcRecordReader(org.apache.hadoop.mapred.JobConf conf, JdbcInputSplit split)

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.hadoop.io.LongWritable	createKey()
org.apache.hadoop.io.MapWritable	createValue()
long	getPos()
float	getProgress()
boolean	next(org.apache.hadoop.io.LongWritable key, org.apache.hadoop.io.MapWritable value)
void	setDbAccessor(DatabaseAccessor dbAccessor)
void	setIterator(JdbcRecordIterator iterator)

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcRecordReader

public JdbcRecordReader(org.apache.hadoop.mapred.JobConf conf,
                        JdbcInputSplit split)

Method Detail

next

public boolean next(org.apache.hadoop.io.LongWritable key,
                    org.apache.hadoop.io.MapWritable value)
             throws IOException

Specified by:

next in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>

Throws:

IOException

createKey

public org.apache.hadoop.io.LongWritable createKey()

Specified by:

createKey in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>

createValue

public org.apache.hadoop.io.MapWritable createValue()

Specified by:

createValue in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>

getPos

public long getPos()
            throws IOException

Specified by:

getPos in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>

Throws:

IOException

getProgress

public float getProgress()
                  throws IOException

Specified by:

getProgress in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>

Throws:

IOException

setDbAccessor

public void setDbAccessor(DatabaseAccessor dbAccessor)

setIterator

public void setIterator(JdbcRecordIterator iterator)