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