public class DocumentDBInputFormat extends org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.LongWritable,DocumentDBWritable>
| Constructor and Description |
|---|
DocumentDBInputFormat() |
| Modifier and Type | Method and Description |
|---|---|
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,DocumentDBWritable> |
createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
Creates an instance of DocumentDBRecordReader
|
List<org.apache.hadoop.mapreduce.InputSplit> |
getSplits(org.apache.hadoop.mapreduce.JobContext context)
Gets a list of DocumentDBInputSplit and validates all the required properties to read from documentdb.
|
public org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,DocumentDBWritable> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
createRecordReader in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.LongWritable,DocumentDBWritable>IOExceptionInterruptedExceptionpublic List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context) throws IOException, InterruptedException
getSplits in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.LongWritable,DocumentDBWritable>IOExceptionInterruptedExceptionCopyright © 2015. All rights reserved.