org.apache.hadoop.mapreduce.lib.db

类 OracleDBRecordReader<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.OracleDBRecordReader<T>

所有已实现的接口:

Closeable, AutoCloseable

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

A RecordReader that reads records from an Oracle SQL table.

字段概要

字段

限定符和类型	字段和说明
static String	SESSION_TIMEZONE_KEY Configuration key to set to a timezone string.

从类继承的字段 org.apache.hadoop.mapreduce.lib.db.DBRecordReader

statement

构造器概要

构造器

构造器和说明
OracleDBRecordReader(DBInputFormat.DBInputSplit split, Class<T> inputClass, Configuration conf, Connection conn, DBConfiguration dbConfig, String cond, String[] fields, String table)

方法概要

方法

限定符和类型	方法和说明
protected String	getSelectQuery() Returns the query for selecting the records from an Oracle DB.
static void	setSessionTimeZone(Configuration conf, Connection conn) Set session time zone

从类继承的方法 org.apache.hadoop.mapreduce.lib.db.DBRecordReader

close, createValue, executeQuery, 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

字段详细资料

SESSION_TIMEZONE_KEY

public static final String SESSION_TIMEZONE_KEY

Configuration key to set to a timezone string.

另请参阅:

常量字段值

构造器详细资料

OracleDBRecordReader

public OracleDBRecordReader(DBInputFormat.DBInputSplit split,
                    Class<T> inputClass,
                    Configuration conf,
                    Connection conn,
                    DBConfiguration dbConfig,
                    String cond,
                    String[] fields,
                    String table)
                     throws SQLException

抛出:

SQLException

方法详细资料

getSelectQuery

protected String getSelectQuery()

Returns the query for selecting the records from an Oracle DB.

覆盖:

getSelectQuery 在类中 DBRecordReader<T extends DBWritable>

setSessionTimeZone

public static void setSessionTimeZone(Configuration conf,
                      Connection conn)
                               throws SQLException

Set session time zone

参数:

conf - The current configuration. We read the 'oracle.sessionTimeZone' property from here.

conn - The connection to alter the timezone properties of.

抛出:

SQLException