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 Object
implements FileSinkOperator.RecordWriter

Write an Avro GenericRecord to an Avro data file.

Constructor Summary

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

Method Summary

void	close(boolean abort)
void	write(org.apache.hadoop.io.Writable writable)

Methods inherited from class java.lang.Object

equals, 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(org.apache.hadoop.io.Writable writable)
           throws IOException

Specified by:

write in interface FileSinkOperator.RecordWriter

Throws:

IOException

close

public void close(boolean abort)
           throws IOException

Specified by:

close in interface FileSinkOperator.RecordWriter

Throws:

IOException