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().
Method Summary |
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)
|
HiveOutputFormatImpl
public HiveOutputFormatImpl()
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
Copyright © 2014 The Apache Software Foundation. All rights reserved.