org.apache.pig.piggybank.storage.avro

Class PigAvroRecordWriter

java.lang.Object

org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,java.lang.Object>

org.apache.pig.piggybank.storage.avro.PigAvroRecordWriter

public class PigAvroRecordWriter
extends org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,java.lang.Object>

The RecordWriter used to output pig results as avro data

Constructor Summary

Constructors

Constructor and Description
PigAvroRecordWriter(org.apache.avro.file.DataFileWriter<java.lang.Object> writer) construct with avro writer

Method Summary

Methods

Modifier and Type	Method and Description
void	close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
void	write(org.apache.hadoop.io.NullWritable key, java.lang.Object value)

Methods inherited from class java.lang.Object

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

Constructor Detail

PigAvroRecordWriter

public PigAvroRecordWriter(org.apache.avro.file.DataFileWriter<java.lang.Object> writer)

construct with avro writer

Parameters:

writer - avro data writer

Method Detail

close

public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
           throws java.io.IOException,
                  java.lang.InterruptedException

Specified by:

close in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,java.lang.Object>

Throws:

java.io.IOException

java.lang.InterruptedException

write

public void write(org.apache.hadoop.io.NullWritable key,
         java.lang.Object value)
           throws java.io.IOException,
                  java.lang.InterruptedException

Specified by:

write in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,java.lang.Object>

Throws:

java.io.IOException

java.lang.InterruptedException