datafu.hourglass.avro
Class AvroKeyWithMetadataOutputFormat.RecordWriterFactory<T>

java.lang.Object
  datafu.hourglass.avro.AvroKeyWithMetadataOutputFormat.RecordWriterFactory<T>

Type Parameters:

T - The java type of the avro record to write.

Enclosing class:

AvroKeyWithMetadataOutputFormat<T>

protected static class AvroKeyWithMetadataOutputFormat.RecordWriterFactory<T>
extends java.lang.Object

A factory for creating record writers.

Constructor Summary

protected

AvroKeyWithMetadataOutputFormat.RecordWriterFactory()

Method Summary

protected org.apache.hadoop.mapreduce.RecordWriter<org.apache.avro.mapred.AvroKey<T>,org.apache.hadoop.io.NullWritable>

create(org.apache.avro.Schema writerSchema, org.apache.avro.file.CodecFactory compressionCodec, java.io.OutputStream outputStream, org.apache.hadoop.conf.Configuration conf) Creates a new record writer instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroKeyWithMetadataOutputFormat.RecordWriterFactory

protected AvroKeyWithMetadataOutputFormat.RecordWriterFactory()

Method Detail

create

protected org.apache.hadoop.mapreduce.RecordWriter<org.apache.avro.mapred.AvroKey<T>,org.apache.hadoop.io.NullWritable> create(org.apache.avro.Schema writerSchema,
                                                                                                                               org.apache.avro.file.CodecFactory compressionCodec,
                                                                                                                               java.io.OutputStream outputStream,
                                                                                                                               org.apache.hadoop.conf.Configuration conf)
                                                                                                                        throws java.io.IOException

Creates a new record writer instance.

Parameters:

writerSchema - The writer schema for the records to write.

compressionCodec - The compression type for the writer file.

outputStream - The target output stream for the records.

Throws:

java.io.IOException