T
- The java type of the avro record to write.protected static class AvroKeyWithMetadataOutputFormat.RecordWriterFactory<T>
extends java.lang.Object
Modifier | Constructor and Description |
---|---|
protected |
AvroKeyWithMetadataOutputFormat.RecordWriterFactory() |
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.
|
protected AvroKeyWithMetadataOutputFormat.RecordWriterFactory()
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
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 configurationjava.io.IOException
- IOException