org.apache.hadoop.mapreduce.lib.db

クラス MySQLDataDrivenDBRecordReader<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.MySQLDataDrivenDBRecordReader<T>

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

Closeable, AutoCloseable

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

A RecordReader that reads records from a MySQL table via DataDrivenDBRecordReader

フィールドのサマリー

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

statement

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

コンストラクタ

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

メソッドのサマリー

修飾子とタイプ	メソッドと説明
protected ResultSet	executeQuery(String query)

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

getSelectQuery

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

close, createValue, 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

コンストラクタの詳細

MySQLDataDrivenDBRecordReader

public MySQLDataDrivenDBRecordReader(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

メソッドの詳細

executeQuery

protected ResultSet executeQuery(String query)
                          throws SQLException

オーバーライド:

executeQuery クラス内 DBRecordReader<T extends DBWritable>

例外:

SQLException