org.apache.hadoop.io

Class SequenceFileBase.BlockCompressWriterBase

java.lang.Object

org.apache.hadoop.io.SequenceFile.Writer

org.apache.hadoop.io.SequenceFileBase.BlockCompressWriterBase

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

AvroSequenceFile.BlockCompressWriter

Enclosing class:

SequenceFileBase

protected abstract static class SequenceFileBase.BlockCompressWriterBase
extends SequenceFile.Writer

Field Summary

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

compressedValSerializer, keySerializer, uncompressedValSerializer

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SequenceFileBase.BlockCompressWriterBase(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, int bufferSize, short replication, long blockSize, CompressionCodec codec, Progressable progress, SequenceFile.Metadata metadata)

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

SequenceFileBase.BlockCompressWriterBase

protected SequenceFileBase.BlockCompressWriterBase(FileSystem fs,
                                        Configuration conf,
                                        Path name,
                                        Class keyClass,
                                        Class valClass,
                                        int bufferSize,
                                        short replication,
                                        long blockSize,
                                        CompressionCodec codec,
                                        Progressable progress,
                                        SequenceFile.Metadata metadata)
                                            throws IOException

Throws:

IOException

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