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

SUBSTITUTE_TOKEN

クラスから継承されたフィールド org.apache.hadoop.mapreduce.lib.db.DBInputFormat

conditions, connection, dbConf, dbProductName, fieldNames, tableName

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
OracleDataDrivenDBInputFormat()

メソッドのサマリー

修飾子とタイプ	メソッドと説明
protected RecordReader<LongWritable,T>	createDBRecordReader(org.apache.hadoop.mapreduce.lib.db.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, createConnection, 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(org.apache.hadoop.mapreduce.lib.db.DBInputFormat.DBInputSplit split,
                                                            Configuration conf)
                                                     throws IOException

オーバーライド:

createDBRecordReader クラス内 DataDrivenDBInputFormat<T extends DBWritable>

例外:

IOException