org.apache.hadoop.mapreduce.lib.db

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

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

Closeable, AutoCloseable

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

A RecordReader that reads records from a MySQL table.

フィールドのサマリー

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

statement

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

コンストラクタ

コンストラクタと説明
MySQLDBRecordReader(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.DBRecordReader

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

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

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

コンストラクタの詳細

MySQLDBRecordReader

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