public class LlapOutputFormat<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable> extends Object implements org.apache.hadoop.mapred.OutputFormat<K,V>, StreamingOutputFormat
Modifier and Type | Field and Description |
---|---|
static String |
LLAP_OF_ID_KEY |
Constructor and Description |
---|
LlapOutputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
checkOutputSpecs(org.apache.hadoop.fs.FileSystem ignored,
org.apache.hadoop.mapred.JobConf job) |
org.apache.hadoop.mapred.RecordWriter<K,V> |
getRecordWriter(org.apache.hadoop.fs.FileSystem ignored,
org.apache.hadoop.mapred.JobConf job,
String name,
org.apache.hadoop.util.Progressable progress) |
public static final String LLAP_OF_ID_KEY
public void checkOutputSpecs(org.apache.hadoop.fs.FileSystem ignored, org.apache.hadoop.mapred.JobConf job) throws IOException
checkOutputSpecs
in interface org.apache.hadoop.mapred.OutputFormat<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable>
IOException
public org.apache.hadoop.mapred.RecordWriter<K,V> getRecordWriter(org.apache.hadoop.fs.FileSystem ignored, org.apache.hadoop.mapred.JobConf job, String name, org.apache.hadoop.util.Progressable progress) throws IOException
getRecordWriter
in interface org.apache.hadoop.mapred.OutputFormat<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable>
IOException
Copyright © 2016 The Apache Software Foundation. All rights reserved.