@InterfaceAudience.Public @InterfaceStability.Stable public class DBConfiguration extends DBConfiguration
Modifier and Type | Field and Description |
---|---|
static String |
DRIVER_CLASS_PROPERTY
The JDBC Driver class name
|
static String |
INPUT_CLASS_PROPERTY
Class name implementing DBWritable which will hold input tuples
|
static String |
INPUT_CONDITIONS_PROPERTY
WHERE clause in the input SELECT statement
|
static String |
INPUT_COUNT_QUERY
Input query to get the count of records
|
static String |
INPUT_FIELD_NAMES_PROPERTY
Field names in the Input table
|
static String |
INPUT_ORDER_BY_PROPERTY
ORDER BY clause in the input SELECT statement
|
static String |
INPUT_QUERY
Whole input query, exluding LIMIT...OFFSET
|
static String |
INPUT_TABLE_NAME_PROPERTY
Input table name
|
static String |
OUTPUT_FIELD_COUNT_PROPERTY
Number of fields in the Output table
|
static String |
OUTPUT_FIELD_NAMES_PROPERTY
Field names in the Output table
|
static String |
OUTPUT_TABLE_NAME_PROPERTY
Output table name
|
static String |
PASSWORD_PROPERTY
Password to access the database
|
static String |
URL_PROPERTY
JDBC Database access URL
|
static String |
USERNAME_PROPERTY
User name to access the database
|
INPUT_BOUNDING_QUERY
Modifier and Type | Method and 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.
|
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
public static final String DRIVER_CLASS_PROPERTY
public static final String URL_PROPERTY
public static final String USERNAME_PROPERTY
public static final String PASSWORD_PROPERTY
public static final String INPUT_TABLE_NAME_PROPERTY
public static final String INPUT_FIELD_NAMES_PROPERTY
public static final String INPUT_CONDITIONS_PROPERTY
public static final String INPUT_ORDER_BY_PROPERTY
public static final String INPUT_QUERY
public static final String INPUT_COUNT_QUERY
public static final String INPUT_CLASS_PROPERTY
public static final String OUTPUT_TABLE_NAME_PROPERTY
public static final String OUTPUT_FIELD_NAMES_PROPERTY
public static final String OUTPUT_FIELD_COUNT_PROPERTY
public static void configureDB(JobConf job, String driverClass, String dbUrl, String userName, String passwd)
job
- the jobdriverClass
- JDBC Driver class namedbUrl
- JDBC DB access URL.userName
- DB access usernamepasswd
- DB access passwdCopyright © 2017 Apache Software Foundation. All rights reserved.