org.apache.hadoop.mapreduce.lib.db

クラス DataDrivenDBRecordReader<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>

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

Closeable, AutoCloseable

直系の既知のサブクラス:

MySQLDataDrivenDBRecordReader, OracleDataDrivenDBRecordReader

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

A RecordReader that reads records from a SQL table, using data-driven WHERE clause splits. Emits LongWritables containing the record number as key and DBWritables as value.

フィールドのサマリー

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

statement

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

コンストラクタ

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

メソッドのサマリー

修飾子とタイプ	メソッドと説明
protected String	getSelectQuery() Returns the query for selecting the records, subclasses can override this for custom behaviour.

クラスから継承されたメソッド 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

コンストラクタの詳細

DataDrivenDBRecordReader

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

パラメータ:

split - The InputSplit to read data for

例外:

SQLException

メソッドの詳細

getSelectQuery

protected String getSelectQuery()

Returns the query for selecting the records, subclasses can override this for custom behaviour.

オーバーライド:

getSelectQuery クラス内 DBRecordReader<T extends DBWritable>