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