org.apache.hadoop.mapreduce.lib.db

Class OracleDataDrivenDBRecordReader<T extends DBWritable>

java.lang.Object

org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,T>

org.apache.hadoop.mapreduce.lib.db.DBRecordReader<T>

org.apache.hadoop.mapreduce.lib.db.DataDrivenDBRecordReader<T>

org.apache.hadoop.mapreduce.lib.db.OracleDataDrivenDBRecordReader<T>

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class OracleDataDrivenDBRecordReader<T extends DBWritable>
extends DataDrivenDBRecordReader<T>

A RecordReader that reads records from a Oracle table via DataDrivenDBRecordReader

Constructor Summary

Constructors

Constructor and Description
OracleDataDrivenDBRecordReader(DBInputFormat.DBInputSplit split, java.lang.Class<T> inputClass, org.apache.hadoop.conf.Configuration conf, java.sql.Connection conn, DBConfiguration dbConfig, java.lang.String cond, java.lang.String[] fields, java.lang.String table)

Method Summary

Methods inherited from class org.apache.hadoop.mapreduce.lib.db.DataDrivenDBRecordReader

getSelectQuery

Methods inherited from class org.apache.hadoop.mapreduce.lib.db.DBRecordReader

close, createValue, executeQuery, getConditions, getConnection, getCurrentKey, getCurrentValue, getDBConf, getFieldNames, getPos, getProgress, getSplit, getStatement, getTableName, initialize, next, nextKeyValue, setStatement

Methods inherited from class java.lang.Object

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

Constructor Detail

OracleDataDrivenDBRecordReader

public OracleDataDrivenDBRecordReader(DBInputFormat.DBInputSplit split,
                              java.lang.Class<T> inputClass,
                              org.apache.hadoop.conf.Configuration conf,
                              java.sql.Connection conn,
                              DBConfiguration dbConfig,
                              java.lang.String cond,
                              java.lang.String[] fields,
                              java.lang.String table)
                               throws java.sql.SQLException

Throws:

java.sql.SQLException