org.apache.hadoop.hive.llap

Class LlapOutputFormat<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.hadoop.hive.llap.LlapOutputFormat<K,V>

All Implemented Interfaces:

StreamingOutputFormat, org.apache.hadoop.mapred.OutputFormat<K,V>

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

Field Summary

Fields

Modifier and Type	Field and Description
static String	LLAP_OF_ID_KEY

Constructor Summary

Constructors

Constructor and Description
LlapOutputFormat()

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LLAP_OF_ID_KEY

public static final String LLAP_OF_ID_KEY

See Also:

Constant Field Values

Constructor Detail

LlapOutputFormat

public LlapOutputFormat()

Method Detail

checkOutputSpecs

public void checkOutputSpecs(org.apache.hadoop.fs.FileSystem ignored,
                             org.apache.hadoop.mapred.JobConf job)
                      throws IOException

Specified by:

checkOutputSpecs in interface org.apache.hadoop.mapred.OutputFormat<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable>

Throws:

IOException

getRecordWriter

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

Specified by:

getRecordWriter in interface org.apache.hadoop.mapred.OutputFormat<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable>

Throws:

IOException