| Package | Description | 
|---|---|
| org.apache.hadoop.mapred.lib.db | |
| org.apache.hadoop.mapreduce.lib.db | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
DBWritable  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
DataDrivenDBInputFormat<T extends DBWritable>
A InputFormat that reads input data from an SQL table. 
 | 
class  | 
DataDrivenDBRecordReader<T extends DBWritable>
A RecordReader that reads records from a SQL table,
 using data-driven WHERE clause splits. 
 | 
class  | 
DBInputFormat<T extends DBWritable>
A InputFormat that reads input data from an SQL table. 
 | 
class  | 
DBOutputFormat<K extends DBWritable,V>
A OutputFormat that sends the reduce output to a SQL table. 
 | 
class  | 
DBRecordReader<T extends DBWritable>
A RecordReader that reads records from a SQL table. 
 | 
class  | 
MySQLDataDrivenDBRecordReader<T extends DBWritable>
A RecordReader that reads records from a MySQL table via DataDrivenDBRecordReader 
 | 
class  | 
MySQLDBRecordReader<T extends DBWritable>
A RecordReader that reads records from a MySQL table. 
 | 
class  | 
OracleDataDrivenDBInputFormat<T extends DBWritable>
A InputFormat that reads input data from an SQL table in an Oracle db. 
 | 
class  | 
OracleDataDrivenDBRecordReader<T extends DBWritable>
A RecordReader that reads records from a Oracle table via DataDrivenDBRecordReader 
 | 
class  | 
OracleDBRecordReader<T extends DBWritable>
A RecordReader that reads records from an Oracle SQL table. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
DBInputFormat.setInput(Job job,
        Class<? extends DBWritable> inputClass,
        String inputQuery,
        String inputCountQuery)
Initializes the map-part of the job with the appropriate input settings. 
 | 
static void | 
DataDrivenDBInputFormat.setInput(Job job,
        Class<? extends DBWritable> inputClass,
        String inputQuery,
        String inputBoundingQuery)
setInput() takes a custom query and a separate "bounding query" to use
      instead of the custom "count query" used by DBInputFormat. 
 | 
static void | 
DBInputFormat.setInput(Job job,
        Class<? extends DBWritable> inputClass,
        String tableName,
        String conditions,
        String orderBy,
        String... fieldNames)
Initializes the map-part of the job with the appropriate input settings. 
 | 
static void | 
DataDrivenDBInputFormat.setInput(Job job,
        Class<? extends DBWritable> inputClass,
        String tableName,
        String conditions,
        String splitBy,
        String... fieldNames)
Note that the "orderBy" column is called the "splitBy" in this version. 
 | 
void | 
DBConfiguration.setInputClass(Class<? extends DBWritable> inputClass)  | 
Copyright © 2022 Apache Software Foundation. All rights reserved.