public static class PTFRowContainer.PTFHiveSequenceFileOutputFormat<K,V> extends HiveSequenceFileOutputFormat<K,V>
| Constructor and Description |
|---|
PTFHiveSequenceFileOutputFormat() |
| Modifier and Type | Method and Description |
|---|---|
FileSinkOperator.RecordWriter |
getHiveRecordWriter(JobConf jc,
Path finalOutPath,
java.lang.Class<? extends Writable> valueClass,
boolean isCompressed,
java.util.Properties tableProperties,
Progressable progress)
create the final out file, and output an empty key as the key.
|
public FileSinkOperator.RecordWriter getHiveRecordWriter(JobConf jc, Path finalOutPath, java.lang.Class<? extends Writable> valueClass, boolean isCompressed, java.util.Properties tableProperties, Progressable progress) throws java.io.IOException
HiveSequenceFileOutputFormatgetHiveRecordWriter in interface HiveOutputFormat<K,V>getHiveRecordWriter in class HiveSequenceFileOutputFormat<K,V>jc - the job configuration filefinalOutPath - the final output file to be createdvalueClass - the value class used for createisCompressed - whether the content is compressed or nottableProperties - the tableInfo of this file's corresponding tableprogress - progress used for status reportjava.io.IOExceptionCopyright © 2012 The Apache Software Foundation