org.apache.hadoop.mapreduce.lib.db

Class MySQLDBRecordReader<T extends DBWritable>

java.lang.Object

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

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

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

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class MySQLDBRecordReader<T extends DBWritable>
extends DBRecordReader<T>

A RecordReader that reads records from a MySQL table.

Constructor Summary

Constructors

Constructor and Description
MySQLDBRecordReader(DBInputFormat.DBInputSplit split, java.lang.Class<T> inputClass, org.apache.hadoop.conf.Configuration conf, java.sql.Connection conn, DBConfiguration dbConfig, java.lang.String cond, java.lang.String[] fields, java.lang.String table)

Method Summary

Methods

Modifier and Type	Method and Description
protected java.sql.ResultSet	executeQuery(java.lang.String query)

Methods inherited from class 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

Methods inherited from class java.lang.Object

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

Constructor Detail

MySQLDBRecordReader

public MySQLDBRecordReader(DBInputFormat.DBInputSplit split,
                   java.lang.Class<T> inputClass,
                   org.apache.hadoop.conf.Configuration conf,
                   java.sql.Connection conn,
                   DBConfiguration dbConfig,
                   java.lang.String cond,
                   java.lang.String[] fields,
                   java.lang.String table)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

Method Detail

executeQuery

protected java.sql.ResultSet executeQuery(java.lang.String query)
                                   throws java.sql.SQLException

Overrides:

executeQuery in class DBRecordReader<T extends DBWritable>

Throws:

java.sql.SQLException