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

All Implemented Interfaces:

Closeable, AutoCloseable, FSHLogProvider.Writer, WALProvider.Writer, WALProvider.WriterBase

Direct Known Subclasses:

SecureProtobufLogWriter

@InterfaceAudience.Private
public class ProtobufLogWriter
extends AbstractProtobufLogWriter
implements FSHLogProvider.Writer

Writer for protobuf-based WAL.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
protected org.apache.hadoop.fs.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(WAL.Entry entry)
void	close()
protected OutputStream	getOutputStreamForCellEncoder()
org.apache.hadoop.fs.FSDataOutputStream	getStream()
protected void	initOutput(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, boolean overwritable, int bufferSize, short replication, long blockSize)
void	sync()
protected long	writeMagicAndWALHeader(byte[] magic, org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.WALHeader header) return the file length after written.
protected long	writeWALTrailerAndMagic(org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.WALTrailer trailer, byte[] magic)

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.wal.FSHLogProvider.Writer

init

Methods inherited from interface org.apache.hadoop.hbase.wal.WALProvider.WriterBase

getLength

Field Detail

LOG

private static final org.slf4j.Logger LOG

output

protected org.apache.hadoop.fs.FSDataOutputStream output

Constructor Detail

ProtobufLogWriter

public ProtobufLogWriter()

Method Detail

append

public void append(WAL.Entry entry)
            throws IOException

Specified by:

append in interface WALProvider.Writer

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

sync

public void sync()
          throws IOException

Specified by:

sync in interface WALProvider.Writer

Throws:

IOException

getStream

public org.apache.hadoop.fs.FSDataOutputStream getStream()

initOutput

protected void initOutput(org.apache.hadoop.fs.FileSystem fs,
                          org.apache.hadoop.fs.Path path,
                          boolean overwritable,
                          int bufferSize,
                          short replication,
                          long blockSize)
                   throws IOException,
                          CommonFSUtils.StreamLacksCapabilityException

Specified by:

initOutput in class AbstractProtobufLogWriter

Throws:

IOException

CommonFSUtils.StreamLacksCapabilityException

writeMagicAndWALHeader

protected long writeMagicAndWALHeader(byte[] magic,
                                      org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.WALHeader header)
                               throws IOException

Description copied from class: AbstractProtobufLogWriter

return the file length after written.

Specified by:

writeMagicAndWALHeader in class AbstractProtobufLogWriter

Throws:

IOException

getOutputStreamForCellEncoder

protected OutputStream getOutputStreamForCellEncoder()

Specified by:

getOutputStreamForCellEncoder in class AbstractProtobufLogWriter

writeWALTrailerAndMagic

protected long writeWALTrailerAndMagic(org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.WALTrailer trailer,
                                       byte[] magic)
                                throws IOException

Specified by:

writeWALTrailerAndMagic in class AbstractProtobufLogWriter

Throws:

IOException