org.apache.avro.hadoop.io

Class AvroSequenceFile.RecordCompressWriter

java.lang.Object

org.apache.hadoop.io.SequenceFile.Writer

org.apache.hadoop.io.SequenceFileBase.RecordCompressWriterBase

org.apache.avro.hadoop.io.AvroSequenceFile.RecordCompressWriter

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

AvroSequenceFile

public static class AvroSequenceFile.RecordCompressWriter
extends SequenceFileBase.RecordCompressWriterBase

A Writer for Avro-enabled SequenceFiles using record-level compression.

Field Summary

Fields inherited from class org.apache.hadoop.io.SequenceFile.Writer

compressedValSerializer, keySerializer, uncompressedValSerializer

Constructor Summary

Constructors

Constructor and Description
AvroSequenceFile.RecordCompressWriter(AvroSequenceFile.Writer.Options options) Creates a new RecordCompressWriter to a SequenceFile that supports Avro data.

Method Summary

Methods

Modifier and Type	Method and Description
void	append(Object arg0, Object arg1)
void	appendRaw(byte[] arg0, int arg1, int arg2, SequenceFile.ValueBytes arg3)

Methods inherited from class org.apache.hadoop.io.SequenceFile.Writer

append, close, getCompressionCodec, getKeyClass, getLength, getValueClass, sync, syncFs

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroSequenceFile.RecordCompressWriter

public AvroSequenceFile.RecordCompressWriter(AvroSequenceFile.Writer.Options options)
                                      throws IOException

Creates a new RecordCompressWriter to a SequenceFile that supports Avro data.

Parameters:

options - The writer options.

Throws:

IOException - If the writer cannot be initialized.

Method Detail

append

public void append(Object arg0,
          Object arg1)
            throws IOException

Overrides:

append in class SequenceFile.Writer

Throws:

IOException

appendRaw

public void appendRaw(byte[] arg0,
             int arg1,
             int arg2,
             SequenceFile.ValueBytes arg3)
               throws IOException

Overrides:

appendRaw in class SequenceFile.Writer

Throws:

IOException