|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use DBWritable | |
---|---|
org.apache.hadoop.mapreduce.lib.db |
Uses of DBWritable in org.apache.hadoop.mapreduce.lib.db |
---|
Classes in org.apache.hadoop.mapreduce.lib.db with type parameters of type DBWritable | |
---|---|
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. |
Classes in org.apache.hadoop.mapreduce.lib.db that implement DBWritable | |
---|---|
static class |
DBInputFormat.NullDBWritable
A Class that does nothing, implementing DBWritable |
Method parameters in org.apache.hadoop.mapreduce.lib.db with type arguments of type DBWritable | |
---|---|
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)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |