org.apache.hadoop.hive.ql.io

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

java.lang.Object

org.apache.hadoop.hive.ql.io.HiveOutputFormatImpl<K,V>

All Implemented Interfaces:

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

public class HiveOutputFormatImpl<K extends org.apache.hadoop.io.WritableComparable<K>,V extends org.apache.hadoop.io.Writable>
extends Object
implements org.apache.hadoop.mapred.OutputFormat<K,V>

Hive does not use OutputFormat's in a conventional way, but constructs and uses the defined OutputFormat for each table from FileSinkOperator. HiveOutputFormatImpl is used for basic setup, especially for calling checkOutputSpecs().

Constructor Summary

Constructors

Constructor and Description
HiveOutputFormatImpl()

Method Summary

Methods

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

Constructor Detail

HiveOutputFormatImpl

public HiveOutputFormatImpl()

Method Detail

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)

Specified by:

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

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.WritableComparable<K>,V extends org.apache.hadoop.io.Writable>

Throws:

IOException