Package org.apache.hadoop.mapred.lib.db

Class DBConfiguration

java.lang.Object

org.apache.hadoop.mapreduce.lib.db.DBConfiguration

org.apache.hadoop.mapred.lib.db.DBConfiguration

@Public
@Stable
public class DBConfiguration
extends DBConfiguration

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DRIVER_CLASS_PROPERTY	The JDBC Driver class name
static final String	INPUT_CLASS_PROPERTY	Class name implementing DBWritable which will hold input tuples
static final String	INPUT_CONDITIONS_PROPERTY	WHERE clause in the input SELECT statement
static final String	INPUT_COUNT_QUERY	Input query to get the count of records
static final String	INPUT_FIELD_NAMES_PROPERTY	Field names in the Input table
static final String	INPUT_ORDER_BY_PROPERTY	ORDER BY clause in the input SELECT statement
static final String	INPUT_QUERY	Whole input query, exluding LIMIT...OFFSET
static final String	INPUT_TABLE_NAME_PROPERTY	Input table name
static final String	OUTPUT_FIELD_COUNT_PROPERTY	Number of fields in the Output table
static final String	OUTPUT_FIELD_NAMES_PROPERTY	Field names in the Output table
static final String	OUTPUT_TABLE_NAME_PROPERTY	Output table name
static final String	PASSWORD_PROPERTY	Password to access the database
static final String	URL_PROPERTY	JDBC Database access URL
static final String	USERNAME_PROPERTY	User name to access the database

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

INPUT_BOUNDING_QUERY

Method Summary

Modifier and Type	Method	Description
static void	configureDB(JobConf job, String driverClass, String dbUrl)	Sets the DB access related fields in the JobConf.
static void	configureDB(JobConf job, String driverClass, String dbUrl, String userName, String passwd)	Sets the DB access related fields in the JobConf.

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

configureDB, configureDB, getConf, getConnection, getInputBoundingQuery, getInputClass, getInputConditions, getInputCountQuery, getInputFieldNames, getInputOrderBy, getInputQuery, getInputTableName, getOutputFieldCount, getOutputFieldNames, getOutputTableName, setInputBoundingQuery, setInputClass, setInputConditions, setInputCountQuery, setInputFieldNames, setInputOrderBy, setInputQuery, setInputTableName, setOutputFieldCount, setOutputFieldNames, setOutputTableName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

DRIVER_CLASS_PROPERTY

public static final String DRIVER_CLASS_PROPERTY

The JDBC Driver class name

See Also:

• Constant Field Values

URL_PROPERTY

public static final String URL_PROPERTY

JDBC Database access URL

See Also:

• Constant Field Values

USERNAME_PROPERTY

public static final String USERNAME_PROPERTY

User name to access the database

See Also:

• Constant Field Values

PASSWORD_PROPERTY

public static final String PASSWORD_PROPERTY

Password to access the database

See Also:

• Constant Field Values

INPUT_TABLE_NAME_PROPERTY

public static final String INPUT_TABLE_NAME_PROPERTY

Input table name

See Also:

• Constant Field Values

INPUT_FIELD_NAMES_PROPERTY

public static final String INPUT_FIELD_NAMES_PROPERTY

Field names in the Input table

See Also:

• Constant Field Values

INPUT_CONDITIONS_PROPERTY

public static final String INPUT_CONDITIONS_PROPERTY

WHERE clause in the input SELECT statement

See Also:

• Constant Field Values

INPUT_ORDER_BY_PROPERTY

public static final String INPUT_ORDER_BY_PROPERTY

ORDER BY clause in the input SELECT statement

See Also:

• Constant Field Values

INPUT_QUERY

public static final String INPUT_QUERY

Whole input query, exluding LIMIT...OFFSET

See Also:

• Constant Field Values

INPUT_COUNT_QUERY

public static final String INPUT_COUNT_QUERY

Input query to get the count of records

See Also:

• Constant Field Values

INPUT_CLASS_PROPERTY

public static final String INPUT_CLASS_PROPERTY

Class name implementing DBWritable which will hold input tuples

See Also:

• Constant Field Values

OUTPUT_TABLE_NAME_PROPERTY

public static final String OUTPUT_TABLE_NAME_PROPERTY

Output table name

See Also:

• Constant Field Values

OUTPUT_FIELD_NAMES_PROPERTY

public static final String OUTPUT_FIELD_NAMES_PROPERTY

Field names in the Output table

See Also:

• Constant Field Values

OUTPUT_FIELD_COUNT_PROPERTY

public static final String OUTPUT_FIELD_COUNT_PROPERTY

Number of fields in the Output table

See Also:

• Constant Field Values

Method Details

configureDB

public static void configureDB(JobConf job,
 String driverClass,
 String dbUrl,
 String userName,
 String passwd)

Sets the DB access related fields in the JobConf.

Parameters:

job - the job

driverClass - JDBC Driver class name

dbUrl - JDBC DB access URL.

userName - DB access username

passwd - DB access passwd

configureDB

public static void configureDB(JobConf job,
 String driverClass,
 String dbUrl)

Sets the DB access related fields in the JobConf.

Parameters:

job - the job

driverClass - JDBC Driver class name

dbUrl - JDBC DB access URL.