org.apache.hadoop.mapreduce.lib.db
Class OracleDataDrivenDBInputFormat<T extends DBWritable>

java.lang.Object
  extended by org.apache.hadoop.mapreduce.InputFormat<LongWritable,T>
      extended by org.apache.hadoop.mapreduce.lib.db.DBInputFormat<T>
          extended by org.apache.hadoop.mapreduce.lib.db.DataDrivenDBInputFormat<T>
              extended by org.apache.hadoop.mapreduce.lib.db.OracleDataDrivenDBInputFormat<T>
All Implemented Interfaces:
Configurable

@InterfaceAudience.Public
@InterfaceStability.Evolving
public class OracleDataDrivenDBInputFormat<T extends DBWritable>
extends DataDrivenDBInputFormat<T>
implements Configurable

A InputFormat that reads input data from an SQL table in an Oracle db.


Field Summary
 
Fields inherited from class org.apache.hadoop.mapreduce.lib.db.DataDrivenDBInputFormat
SUBSTITUTE_TOKEN
 
Fields inherited from class org.apache.hadoop.mapreduce.lib.db.DBInputFormat
conditions, connection, dbConf, dbProductName, fieldNames, tableName
 
Constructor Summary
OracleDataDrivenDBInputFormat()
           
 
Method Summary
protected  RecordReader<LongWritable,T> createDBRecordReader(org.apache.hadoop.mapreduce.lib.db.DBInputFormat.DBInputSplit split, Configuration conf)
           
protected  DBSplitter getSplitter(int sqlDataType)
           
 
Methods inherited from class org.apache.hadoop.mapreduce.lib.db.DataDrivenDBInputFormat
getBoundingValsQuery, getSplits, setBoundingQuery, setInput, setInput
 
Methods inherited from class org.apache.hadoop.mapreduce.lib.db.DBInputFormat
closeConnection, createRecordReader, getConf, getConnection, getCountQuery, getDBConf, getDBProductName, setConf
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.hadoop.conf.Configurable
getConf, setConf
 

Constructor Detail

OracleDataDrivenDBInputFormat

public OracleDataDrivenDBInputFormat()
Method Detail

getSplitter

protected DBSplitter getSplitter(int sqlDataType)
Overrides:
getSplitter in class DataDrivenDBInputFormat<T extends DBWritable>
Returns:
the DBSplitter implementation to use to divide the table/query into InputSplits.

createDBRecordReader

protected RecordReader<LongWritable,T> createDBRecordReader(org.apache.hadoop.mapreduce.lib.db.DBInputFormat.DBInputSplit split,
                                                            Configuration conf)
                                                                        throws IOException
Overrides:
createDBRecordReader in class DataDrivenDBInputFormat<T extends DBWritable>
Throws:
IOException


Copyright © 2014 Apache Software Foundation. All Rights Reserved.