public class DocumentDBOutputFormat extends Object implements org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.Writable,DocumentDBWritable>
Constructor and Description |
---|
DocumentDBOutputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
checkOutputSpecs(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.mapred.JobConf conf)
Validates the required properties needed to write to documentdb.
|
org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.Writable,DocumentDBWritable> |
getRecordWriter(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.mapred.JobConf conf,
String arg2,
org.apache.hadoop.util.Progressable arg3)
Creates an instance of DocumentDBRecordWriter.
|
public void checkOutputSpecs(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.mapred.JobConf conf) throws IOException
checkOutputSpecs
in interface org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.Writable,DocumentDBWritable>
IOException
public org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.Writable,DocumentDBWritable> getRecordWriter(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.mapred.JobConf conf, String arg2, org.apache.hadoop.util.Progressable arg3) throws IOException
getRecordWriter
in interface org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.Writable,DocumentDBWritable>
IOException
Copyright © 2015. All rights reserved.