org.apache.hadoop.mapreduce.lib.db

类 OracleDataDrivenDBInputFormat<T extends DBWritable>

java.lang.Object

org.apache.hadoop.mapreduce.InputFormat<LongWritable,T>

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

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

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

所有已实现的接口:

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.

嵌套类概要

从类继承的嵌套类/接口 org.apache.hadoop.mapreduce.lib.db.DataDrivenDBInputFormat

DataDrivenDBInputFormat.DataDrivenDBInputSplit

从类继承的嵌套类/接口 org.apache.hadoop.mapreduce.lib.db.DBInputFormat

DBInputFormat.DBInputSplit, DBInputFormat.NullDBWritable

字段概要

从类继承的字段 org.apache.hadoop.mapreduce.lib.db.DataDrivenDBInputFormat

SUBSTITUTE_TOKEN

构造器概要

构造器

构造器和说明
OracleDataDrivenDBInputFormat()

方法概要

方法

限定符和类型	方法和说明
protected RecordReader<LongWritable,T>	createDBRecordReader(DBInputFormat.DBInputSplit split, Configuration conf)
protected DBSplitter	getSplitter(int sqlDataType)

从类继承的方法 org.apache.hadoop.mapreduce.lib.db.DataDrivenDBInputFormat

getBoundingValsQuery, getSplits, setBoundingQuery, setInput, setInput

从类继承的方法 org.apache.hadoop.mapreduce.lib.db.DBInputFormat

closeConnection, createRecordReader, getConf, getConnection, getCountQuery, getDBConf, getDBProductName, setConf

从类继承的方法 java.lang.Object

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

从接口继承的方法 org.apache.hadoop.conf.Configurable

getConf, setConf

构造器详细资料

OracleDataDrivenDBInputFormat

public OracleDataDrivenDBInputFormat()

方法详细资料

getSplitter

protected DBSplitter getSplitter(int sqlDataType)

覆盖:

getSplitter 在类中 DataDrivenDBInputFormat<T extends DBWritable>

返回:

the DBSplitter implementation to use to divide the table/query into InputSplits.

createDBRecordReader

protected RecordReader<LongWritable,T> createDBRecordReader(DBInputFormat.DBInputSplit split,
                                                Configuration conf)
                                                                        throws IOException

覆盖:

createDBRecordReader 在类中 DataDrivenDBInputFormat<T extends DBWritable>

抛出:

IOException