@InterfaceAudience.Public @InterfaceStability.Evolving public class OracleDataDrivenDBInputFormat<T extends DBWritable> extends DataDrivenDBInputFormat<T> implements Configurable
DataDrivenDBInputFormat.DataDrivenDBInputSplit
DBInputFormat.DBInputSplit, DBInputFormat.NullDBWritable
SUBSTITUTE_TOKEN
构造器和说明 |
---|
OracleDataDrivenDBInputFormat() |
限定符和类型 | 方法和说明 |
---|---|
protected RecordReader<LongWritable,T> |
createDBRecordReader(DBInputFormat.DBInputSplit split,
Configuration conf) |
protected DBSplitter |
getSplitter(int sqlDataType) |
getBoundingValsQuery, getSplits, setBoundingQuery, setInput, setInput
closeConnection, 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
在类中 DataDrivenDBInputFormat<T extends DBWritable>
protected RecordReader<LongWritable,T> createDBRecordReader(DBInputFormat.DBInputSplit split, Configuration conf) throws IOException
createDBRecordReader
在类中 DataDrivenDBInputFormat<T extends DBWritable>
IOException
Copyright © 2009 The Apache Software Foundation