public class DocumentDBInputFormat extends Object implements org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.LongWritable,DocumentDBWritable>
| Constructor and Description |
|---|
DocumentDBInputFormat() |
| Modifier and Type | Method and Description |
|---|---|
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,DocumentDBWritable> |
getRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.mapred.JobConf conf,
org.apache.hadoop.mapred.Reporter reporter)
Creates an instance of DocumentDBRecordReader
|
org.apache.hadoop.mapred.InputSplit[] |
getSplits(org.apache.hadoop.mapred.JobConf conf,
int numberOfSplits)
Gets an array of DocumentDBInputSplit and validates all the required properties to read from documentdb.
|
public org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,DocumentDBWritable> getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.mapred.Reporter reporter) throws IOException
getRecordReader in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.LongWritable,DocumentDBWritable>IOExceptionpublic org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf conf,
int numberOfSplits)
throws IOException
getSplits in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.LongWritable,DocumentDBWritable>IOExceptionCopyright © 2015. All rights reserved.