org.apache.hadoop.hive.ql.io.avro

Class AvroGenericRecordWriter

java.lang.Object

org.apache.hadoop.hive.ql.io.avro.AvroGenericRecordWriter

All Implemented Interfaces:

FileSinkOperator.RecordWriter

public class AvroGenericRecordWriter
extends java.lang.Object
implements FileSinkOperator.RecordWriter

Write an Avro GenericRecord to an Avro data file.

Constructor Summary

Constructors

Constructor and Description
AvroGenericRecordWriter(org.apache.avro.file.DataFileWriter<org.apache.avro.generic.GenericRecord> dfw)

Method Summary

Modifier and Type	Method and Description
void	close(boolean abort)
void	write(Writable writable)

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroGenericRecordWriter

public AvroGenericRecordWriter(org.apache.avro.file.DataFileWriter<org.apache.avro.generic.GenericRecord> dfw)

Method Detail

write

public void write(Writable writable)
           throws java.io.IOException

Specified by:

write in interface FileSinkOperator.RecordWriter

Throws:

java.io.IOException

close

public void close(boolean abort)
           throws java.io.IOException

Specified by:

close in interface FileSinkOperator.RecordWriter

Throws:

java.io.IOException