org.apache.hadoop.mapreduce.lib.db
Class 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>

All Implemented Interfaces:

Closeable

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

A RecordReader that reads records from a MySQL table via DataDrivenDBRecordReader

Field Summary

Fields inherited from class org.apache.hadoop.mapreduce.lib.db.DBRecordReader

statement

Constructor Summary

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)

Method Summary

protected ResultSet

executeQuery(String query)

Methods inherited from class org.apache.hadoop.mapreduce.lib.db.DataDrivenDBRecordReader

getSelectQuery

Methods inherited from class org.apache.hadoop.mapreduce.lib.db.DBRecordReader

close, createValue, getConditions, getConnection, getCurrentKey, getCurrentValue, getDBConf, getFieldNames, getPos, getProgress, 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

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

Throws:

SQLException

Method Detail

executeQuery

protected ResultSet executeQuery(String query)
                          throws SQLException

Overrides:

executeQuery in class DBRecordReader<T extends DBWritable>

Throws:

SQLException