Uses of Interface
org.apache.hadoop.mapreduce.lib.db.DBWritable
Packages that use DBWritable
-
Uses of DBWritable in org.apache.hadoop.mapred.lib.db
Subinterfaces of DBWritable in org.apache.hadoop.mapred.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 DBWritableModifier and TypeClassDescriptionclassDataDrivenDBInputFormat<T extends DBWritable>A InputFormat that reads input data from an SQL table.classDataDrivenDBRecordReader<T extends DBWritable>A RecordReader that reads records from a SQL table, using data-driven WHERE clause splits.classDBInputFormat<T extends DBWritable>A InputFormat that reads input data from an SQL table.classDBOutputFormat<K extends DBWritable,V> A OutputFormat that sends the reduce output to a SQL table.classDBRecordReader<T extends DBWritable>A RecordReader that reads records from a SQL table.classMySQLDataDrivenDBRecordReader<T extends DBWritable>A RecordReader that reads records from a MySQL table via DataDrivenDBRecordReaderclassMySQLDBRecordReader<T extends DBWritable>A RecordReader that reads records from a MySQL table.classOracleDataDrivenDBInputFormat<T extends DBWritable>A InputFormat that reads input data from an SQL table in an Oracle db.classOracleDataDrivenDBRecordReader<T extends DBWritable>A RecordReader that reads records from a Oracle table via DataDrivenDBRecordReaderclassOracleDBRecordReader<T extends DBWritable>A RecordReader that reads records from an Oracle SQL table.Method parameters in org.apache.hadoop.mapreduce.lib.db with type arguments of type DBWritableModifier and TypeMethodDescriptionstatic voidDataDrivenDBInputFormat.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 voidDataDrivenDBInputFormat.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.static voidDBInputFormat.setInput(Job job, Class<? extends DBWritable> inputClass, String inputQuery, String inputCountQuery) Initializes the map-part of the job with the appropriate input settings.static voidDBInputFormat.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.voidDBConfiguration.setInputClass(Class<? extends DBWritable> inputClass)