org.apache.pig.piggybank.storage.avro
Class PigAvroRecordWriter
java.lang.Object
org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,Object>
org.apache.pig.piggybank.storage.avro.PigAvroRecordWriter
public class PigAvroRecordWriter
- extends org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,Object>
The RecordWriter used to output pig results as avro data
Method Summary |
void |
close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
|
void |
write(org.apache.hadoop.io.NullWritable key,
Object value)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PigAvroRecordWriter
public PigAvroRecordWriter(org.apache.avro.file.DataFileWriter<Object> writer)
- construct with avro writer
- Parameters:
writer
- avro data writer
close
public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
throws IOException,
InterruptedException
- Specified by:
close
in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,Object>
- Throws:
IOException
InterruptedException
write
public void write(org.apache.hadoop.io.NullWritable key,
Object value)
throws IOException,
InterruptedException
- Specified by:
write
in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,Object>
- Throws:
IOException
InterruptedException
Copyright © ${year} The Apache Software Foundation