org.apache.avro.hadoop.io

Class AvroSequenceFile.BlockCompressWriter

java.lang.Object

org.apache.hadoop.io.SequenceFile.Writer

org.apache.hadoop.io.SequenceFileBase.BlockCompressWriterBase

org.apache.avro.hadoop.io.AvroSequenceFile.BlockCompressWriter

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

AvroSequenceFile

public static class AvroSequenceFile.BlockCompressWriter
extends SequenceFileBase.BlockCompressWriterBase

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

Field Summary

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

compressedValSerializer, keySerializer, uncompressedValSerializer

Constructor Summary

Constructors

Constructor and Description
AvroSequenceFile.BlockCompressWriter(AvroSequenceFile.Writer.Options options) Creates a new BlockCompressWriter 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)
void	close()
void	sync()

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

append, getCompressionCodec, getKeyClass, getLength, getValueClass, syncFs

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroSequenceFile.BlockCompressWriter

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

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

Parameters:

options - The writer options.

Throws:

IOException - If the writer cannot be initialized.

Method Detail

sync

public void sync()
          throws IOException

Overrides:

sync in class SequenceFile.Writer

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class SequenceFile.Writer

Throws:

IOException

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