org.apache.hadoop.mapreduce.lib.db

クラス OracleDataDrivenDBRecordReader<T extends DBWritable>

java.lang.Object

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

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

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

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

すべての実装されたインタフェース:

Closeable, AutoCloseable

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public class OracleDataDrivenDBRecordReader<T extends DBWritable>
extends DataDrivenDBRecordReader<T>

A RecordReader that reads records from a Oracle table via DataDrivenDBRecordReader

フィールドのサマリー

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

statement

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

コンストラクタ

コンストラクタと説明
OracleDataDrivenDBRecordReader(org.apache.hadoop.mapreduce.lib.db.DBInputFormat.DBInputSplit split, Class<T> inputClass, Configuration conf, Connection conn, DBConfiguration dbConfig, String cond, String[] fields, String table)

メソッドのサマリー

クラスから継承されたメソッド org.apache.hadoop.mapreduce.lib.db.DataDrivenDBRecordReader

getSelectQuery

クラスから継承されたメソッド org.apache.hadoop.mapreduce.lib.db.DBRecordReader

close, createValue, executeQuery, getConditions, getConnection, getCurrentKey, getCurrentValue, getDBConf, getFieldNames, getPos, getProgress, getSplit, getStatement, getTableName, initialize, next, nextKeyValue, setStatement

クラスから継承されたメソッド java.lang.Object

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

コンストラクタの詳細

OracleDataDrivenDBRecordReader

public OracleDataDrivenDBRecordReader(org.apache.hadoop.mapreduce.lib.db.DBInputFormat.DBInputSplit split,
                                      Class<T> inputClass,
                                      Configuration conf,
                                      Connection conn,
                                      DBConfiguration dbConfig,
                                      String cond,
                                      String[] fields,
                                      String table)
                               throws SQLException

例外:

SQLException