public class HiveIgnoreKeyTextOutputFormat<K extends WritableComparable,V extends Writable> extends <any> implements HiveOutputFormat<K,V>
Modifier and Type | Class and Description |
---|---|
protected static class |
HiveIgnoreKeyTextOutputFormat.IgnoreKeyWriter<K extends WritableComparable,V extends Writable> |
Constructor and Description |
---|
HiveIgnoreKeyTextOutputFormat() |
Modifier and Type | Method and Description |
---|---|
FileSinkOperator.RecordWriter |
getHiveRecordWriter(JobConf jc,
Path outPath,
java.lang.Class<? extends Writable> valueClass,
boolean isCompressed,
java.util.Properties tableProperties,
Progressable progress)
create the final out file, and output row by row.
|
<any> |
getRecordWriter(FileSystem ignored,
JobConf job,
java.lang.String name,
Progressable progress) |
public FileSinkOperator.RecordWriter getHiveRecordWriter(JobConf jc, Path outPath, java.lang.Class<? extends Writable> valueClass, boolean isCompressed, java.util.Properties tableProperties, Progressable progress) throws java.io.IOException
getHiveRecordWriter
in interface HiveOutputFormat<K extends WritableComparable,V extends Writable>
jc
- the job configuration fileoutPath
- the final output file to be createdvalueClass
- the value class used for createisCompressed
- whether the content is compressed or nottableProperties
- the tableProperties of this file's corresponding tableprogress
- progress used for status reportjava.io.IOException
public <any> getRecordWriter(FileSystem ignored, JobConf job, java.lang.String name, Progressable progress) throws java.io.IOException
java.io.IOException
Copyright © 2012 The Apache Software Foundation