org.apache.pig.impl.util.avro

Class AvroRecordWriter

java.lang.Object

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

org.apache.pig.impl.util.avro.AvroRecordWriter

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

RecordWriter for Avro objects.

Constructor Summary

Constructors

Constructor and Description
AvroRecordWriter(org.apache.hadoop.fs.Path o, org.apache.hadoop.conf.Configuration c) Creates new AvroRecordWriter.

Method Summary

Modifier and Type	Method and Description
void	close(org.apache.hadoop.mapreduce.TaskAttemptContext arg0)
void	prepareToWrite(org.apache.avro.Schema s)
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

AvroRecordWriter

public AvroRecordWriter(org.apache.hadoop.fs.Path o,
                        org.apache.hadoop.conf.Configuration c)
                 throws java.io.IOException

Creates new AvroRecordWriter.

Parameters:

s - Schema for the files on this output path

o - Output path

c - Hadoop configuration

Throws:

java.io.IOException

Method Detail

close

public void close(org.apache.hadoop.mapreduce.TaskAttemptContext arg0)
           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

prepareToWrite

public void prepareToWrite(org.apache.avro.Schema s)
                    throws java.io.IOException

Throws:

java.io.IOException