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

Constructors

Modifier	Constructor and Description
protected	AvroKeyWithMetadataOutputFormat.RecordWriterFactory()

Method Summary

Methods

Modifier and Type	Method and Description
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.

conf - the configuration

Returns:

record writer

Throws:

java.io.IOException - IOException