@InterfaceAudience.Public @InterfaceStability.Evolving public class OracleDataDrivenDBInputFormat<T extends DBWritable> extends DataDrivenDBInputFormat<T> implements Configurable
SUBSTITUTE_TOKEN
conditions, connection, dbConf, dbProductName, fieldNames, tableName
Constructor and Description |
---|
OracleDataDrivenDBInputFormat() |
Modifier and Type | Method and Description |
---|---|
protected RecordReader<LongWritable,T> |
createDBRecordReader(org.apache.hadoop.mapreduce.lib.db.DBInputFormat.DBInputSplit split,
Configuration conf) |
protected DBSplitter |
getSplitter(int sqlDataType) |
getBoundingValsQuery, getSplits, setBoundingQuery, setInput, setInput
closeConnection, createConnection, createRecordReader, getConf, getConnection, getCountQuery, getDBConf, getDBProductName, setConf
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getConf, setConf
protected DBSplitter getSplitter(int sqlDataType)
getSplitter
in class DataDrivenDBInputFormat<T extends DBWritable>
protected RecordReader<LongWritable,T> createDBRecordReader(org.apache.hadoop.mapreduce.lib.db.DBInputFormat.DBInputSplit split, Configuration conf) throws IOException
createDBRecordReader
in class DataDrivenDBInputFormat<T extends DBWritable>
IOException
Copyright © 2021 Apache Software Foundation. All rights reserved.