public class AvroContainerOutputFormat extends java.lang.Object implements HiveOutputFormat<LongWritable,AvroGenericRecordWritable>
Constructor and Description |
---|
AvroContainerOutputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
checkOutputSpecs(FileSystem ignored,
JobConf job) |
FileSinkOperator.RecordWriter |
getHiveRecordWriter(JobConf jobConf,
Path path,
java.lang.Class<? extends Writable> valueClass,
boolean isCompressed,
java.util.Properties properties,
Progressable progressable)
create the final out file and get some specific settings.
|
<any> |
getRecordWriter(FileSystem ignored,
JobConf job,
java.lang.String name,
Progressable progress) |
public FileSinkOperator.RecordWriter getHiveRecordWriter(JobConf jobConf, Path path, java.lang.Class<? extends Writable> valueClass, boolean isCompressed, java.util.Properties properties, Progressable progressable) throws java.io.IOException
HiveOutputFormat
getHiveRecordWriter
in interface HiveOutputFormat<LongWritable,AvroGenericRecordWritable>
jobConf
- the job configuration filepath
- the final output file to be createdvalueClass
- the value class used for createisCompressed
- whether the content is compressed or notproperties
- the table properties of this file's corresponding tableprogressable
- progress used for status reportjava.io.IOException
public <any> getRecordWriter(FileSystem ignored, JobConf job, java.lang.String name, Progressable progress)
public void checkOutputSpecs(FileSystem ignored, JobConf job) throws java.io.IOException
java.io.IOException
Copyright © 2012 The Apache Software Foundation