public class OracleDBRecordReader<T extends DBWritable> extends DBRecordReader<T>
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
SESSION_TIMEZONE_KEY
Configuration key to set to a timezone string.
|
Constructor and Description |
---|
OracleDBRecordReader(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) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.String |
getSelectQuery()
Returns the query for selecting the records from an Oracle DB.
|
static void |
setSessionTimeZone(org.apache.hadoop.conf.Configuration conf,
java.sql.Connection conn)
Set session time zone
|
close, createValue, executeQuery, getConditions, getConnection, getCurrentKey, getCurrentValue, getDBConf, getFieldNames, getPos, getProgress, getSplit, getStatement, getTableName, initialize, next, nextKeyValue, setStatement
public static final java.lang.String SESSION_TIMEZONE_KEY
public OracleDBRecordReader(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
java.sql.SQLException
protected java.lang.String getSelectQuery()
getSelectQuery
in class DBRecordReader<T extends DBWritable>
public static void setSessionTimeZone(org.apache.hadoop.conf.Configuration conf, java.sql.Connection conn) throws java.sql.SQLException
conf
- The current configuration.
We read the 'oracle.sessionTimeZone' property from here.conn
- The connection to alter the timezone properties of.java.sql.SQLException
Copyright © 2009 The Apache Software Foundation