org.apache.hadoop.hive.ql.exec.persistence
Class PTFRowContainer.PTFHiveSequenceFileOutputFormat<K,V>

java.lang.Object
  org.apache.hadoop.mapred.FileOutputFormat<K,V>
      org.apache.hadoop.mapred.SequenceFileOutputFormat<K,V>
          org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat<K,V>
              org.apache.hadoop.hive.ql.exec.persistence.PTFRowContainer.PTFHiveSequenceFileOutputFormat<K,V>

All Implemented Interfaces:

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

Enclosing class:

PTFRowContainer<Row extends List<Object>>

public static class PTFRowContainer.PTFHiveSequenceFileOutputFormat<K,V>
extends HiveSequenceFileOutputFormat<K,V>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapred.FileOutputFormat

org.apache.hadoop.mapred.FileOutputFormat.Counter

Constructor Summary

PTFRowContainer.PTFHiveSequenceFileOutputFormat()

Method Summary

FileSinkOperator.RecordWriter

getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jc, org.apache.hadoop.fs.Path finalOutPath, Class<? extends org.apache.hadoop.io.Writable> valueClass, boolean isCompressed, Properties tableProperties, org.apache.hadoop.util.Progressable progress) create the final out file, and output an empty key as the key.

Methods inherited from class org.apache.hadoop.mapred.SequenceFileOutputFormat

getOutputCompressionType, getReaders, getRecordWriter, setOutputCompressionType

Methods inherited from class org.apache.hadoop.mapred.FileOutputFormat

checkOutputSpecs, getCompressOutput, getOutputCompressorClass, getOutputPath, getPathForCustomFile, getTaskOutputPath, getUniqueName, getWorkOutputPath, setCompressOutput, setOutputCompressorClass, setOutputPath, setWorkOutputPath

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.mapred.OutputFormat

checkOutputSpecs, getRecordWriter

Constructor Detail

PTFRowContainer.PTFHiveSequenceFileOutputFormat

public PTFRowContainer.PTFHiveSequenceFileOutputFormat()

Method Detail

getHiveRecordWriter

public FileSinkOperator.RecordWriter getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jc,
                                                         org.apache.hadoop.fs.Path finalOutPath,
                                                         Class<? extends org.apache.hadoop.io.Writable> valueClass,
                                                         boolean isCompressed,
                                                         Properties tableProperties,
                                                         org.apache.hadoop.util.Progressable progress)
                                                  throws IOException

Description copied from class: HiveSequenceFileOutputFormat

create the final out file, and output an empty key as the key.

Specified by:

getHiveRecordWriter in interface HiveOutputFormat<K,V>

Overrides:

getHiveRecordWriter in class HiveSequenceFileOutputFormat<K,V>

Parameters:

jc - the job configuration file

finalOutPath - the final output file to be created

valueClass - the value class used for create

isCompressed - whether the content is compressed or not

tableProperties - the tableInfo of this file's corresponding table

progress - progress used for status report

Returns:

the RecordWriter for the output file

Throws:

IOException