org.apache.hadoop.hbase.regionserver.wal

Class SequenceFileLogWriter

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.WriterBase

org.apache.hadoop.hbase.regionserver.wal.SequenceFileLogWriter

All Implemented Interfaces:

Closeable, AutoCloseable, DefaultWALProvider.Writer, WALProvider.Writer

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class SequenceFileLogWriter
extends WriterBase

Implementation of WALProvider.Writer that delegates to SequenceFile.Writer. Legacy implementation only used for compat tests. Note that because this class writes to the legacy hadoop-specific SequenceFile format, users of it must write HLogKey keys and not arbitrary WALKeys because the latter are not Writables (nor made to work with Hadoop serialization).

Field Summary

Fields inherited from class org.apache.hadoop.hbase.regionserver.wal.WriterBase

compressionContext, conf

Constructor Summary

Constructors

Constructor and Description
SequenceFileLogWriter() Default constructor.

Method Summary

Modifier and Type	Method and Description
void	append(WAL.Entry entry)
void	close()
long	getLength()
FSDataOutputStream	getWriterFSDataOutputStream()
void	init(FileSystem fs, Path path, Configuration conf, boolean overwritable)
void	sync()

Methods inherited from class org.apache.hadoop.hbase.regionserver.wal.WriterBase

initializeCompressionContext

Methods inherited from class java.lang.Object

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

Constructor Detail

SequenceFileLogWriter

public SequenceFileLogWriter()

Default constructor.

Method Detail

init

public void init(FileSystem fs,
                 Path path,
                 Configuration conf,
                 boolean overwritable)
          throws IOException

Specified by:

init in interface DefaultWALProvider.Writer

Overrides:

init in class WriterBase

Throws:

IOException

append

public void append(WAL.Entry entry)
            throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException

sync

public void sync()
          throws IOException

Throws:

IOException

getLength

public long getLength()
               throws IOException

Throws:

IOException

getWriterFSDataOutputStream

public FSDataOutputStream getWriterFSDataOutputStream()

Returns:

The dfsclient out stream up inside SF.Writer made accessible, or null if not available.