org.apache.hadoop.hbase.regionserver.wal

Class ProtobufLogWriter

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.AbstractProtobufLogWriter

org.apache.hadoop.hbase.regionserver.wal.ProtobufLogWriter

Direct Known Subclasses:

SecureProtobufLogWriter

public class ProtobufLogWriter
extends AbstractProtobufLogWriter

Writer for protobuf-based WAL.

Field Summary

Fields

Modifier and Type	Field and Description
protected FSDataOutputStream	output

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

cellEncoder, compressionContext, compressor, conf, length, trailer, trailerWarnSize, trailerWritten

Constructor Summary

Constructors

Constructor and Description
ProtobufLogWriter()

Method Summary

Modifier and Type	Method and Description
void	append(Entry entry)
void	close()
protected java.io.OutputStream	getOutputStreamForCellEncoder()
FSDataOutputStream	getStream()
protected void	initOutput(FileSystem fs, Path path, boolean overwritable, int bufferSize, short replication, long blockSize)
void	sync()
protected long	writeMagicAndWALHeader(byte[] magic, WALHeader header) return the file length after written.
protected long	writeWALTrailerAndMagic(WALTrailer trailer, byte[] magic)

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

buildSecureWALHeader, buildWALHeader, getLength, getWriterClassName, init, initAfterHeader, secureInitAfterHeader, setEncryptor, writeWALTrailer

Methods inherited from class java.lang.Object

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

Field Detail

output

protected FSDataOutputStream output

Constructor Detail

ProtobufLogWriter

public ProtobufLogWriter()

Method Detail

append

public void append(Entry entry)
            throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

sync

public void sync()
          throws java.io.IOException

Throws:

java.io.IOException

getStream

public FSDataOutputStream getStream()

initOutput

protected void initOutput(FileSystem fs,
                          Path path,
                          boolean overwritable,
                          int bufferSize,
                          short replication,
                          long blockSize)
                   throws java.io.IOException,
                          StreamLacksCapabilityException

Specified by:

initOutput in class AbstractProtobufLogWriter

Throws:

java.io.IOException

StreamLacksCapabilityException

writeMagicAndWALHeader

protected long writeMagicAndWALHeader(byte[] magic,
                                      WALHeader header)
                               throws java.io.IOException

Description copied from class: AbstractProtobufLogWriter

return the file length after written.

Specified by:

writeMagicAndWALHeader in class AbstractProtobufLogWriter

Throws:

java.io.IOException

getOutputStreamForCellEncoder

protected java.io.OutputStream getOutputStreamForCellEncoder()

Specified by:

getOutputStreamForCellEncoder in class AbstractProtobufLogWriter

writeWALTrailerAndMagic

protected long writeWALTrailerAndMagic(WALTrailer trailer,
                                       byte[] magic)
                                throws java.io.IOException

Specified by:

writeWALTrailerAndMagic in class AbstractProtobufLogWriter

Throws:

java.io.IOException