org.apache.hadoop.hbase.regionserver.wal

Class AbstractProtobufLogWriter

java.lang.Object

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

Direct Known Subclasses:

AsyncProtobufLogWriter, ProtobufLogWriter

public abstract class AbstractProtobufLogWriter
extends java.lang.Object

Base class for Protobuf log writer.

Field Summary

Fields

Modifier and Type	Field and Description
protected Codec.Encoder	cellEncoder
protected CompressionContext	compressionContext
protected WALCellCodec.ByteStringCompressor	compressor
protected Configuration	conf
protected java.util.concurrent.atomic.AtomicLong	length
protected WALTrailer	trailer
protected int	trailerWarnSize
protected boolean	trailerWritten

Constructor Summary

Constructors

Constructor and Description
AbstractProtobufLogWriter()

Method Summary

Modifier and Type	Method and Description
protected WALHeader	buildSecureWALHeader(Configuration conf, WALHeader.Builder builder)
protected WALHeader	buildWALHeader(Configuration conf, WALHeader.Builder builder)
long	getLength()
protected abstract java.io.OutputStream	getOutputStreamForCellEncoder()
protected java.lang.String	getWriterClassName()
void	init(FileSystem fs, Path path, Configuration conf, boolean overwritable, long blocksize)
protected void	initAfterHeader(boolean doCompress)
protected abstract void	initOutput(FileSystem fs, Path path, boolean overwritable, int bufferSize, short replication, long blockSize)
protected void	secureInitAfterHeader(boolean doCompress, Encryptor encryptor)
protected void	setEncryptor(Encryptor encryptor)
protected abstract long	writeMagicAndWALHeader(byte[] magic, WALHeader header) return the file length after written.
protected void	writeWALTrailer()
protected abstract long	writeWALTrailerAndMagic(WALTrailer trailer, byte[] magic)

Methods inherited from class java.lang.Object

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

Field Detail

compressionContext

protected CompressionContext compressionContext

conf

protected Configuration conf

cellEncoder

protected Codec.Encoder cellEncoder

compressor

protected WALCellCodec.ByteStringCompressor compressor

trailerWritten

protected boolean trailerWritten

trailer

protected WALTrailer trailer

trailerWarnSize

protected int trailerWarnSize

length

protected java.util.concurrent.atomic.AtomicLong length

Constructor Detail

AbstractProtobufLogWriter

public AbstractProtobufLogWriter()

Method Detail

buildWALHeader

protected WALHeader buildWALHeader(Configuration conf,
                                   WALHeader.Builder builder)
                            throws java.io.IOException

Throws:

java.io.IOException

buildSecureWALHeader

protected final WALHeader buildSecureWALHeader(Configuration conf,
                                               WALHeader.Builder builder)
                                        throws java.io.IOException

Throws:

java.io.IOException

setEncryptor

protected void setEncryptor(Encryptor encryptor)

getWriterClassName

protected java.lang.String getWriterClassName()

init

public void init(FileSystem fs,
                 Path path,
                 Configuration conf,
                 boolean overwritable,
                 long blocksize)
          throws java.io.IOException,
                 StreamLacksCapabilityException

Throws:

java.io.IOException

StreamLacksCapabilityException

initAfterHeader

protected void initAfterHeader(boolean doCompress)
                        throws java.io.IOException

Throws:

java.io.IOException

secureInitAfterHeader

protected final void secureInitAfterHeader(boolean doCompress,
                                           Encryptor encryptor)
                                    throws java.io.IOException

Throws:

java.io.IOException

getLength

public long getLength()

writeWALTrailer

protected void writeWALTrailer()

initOutput

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

Throws:

java.io.IOException

StreamLacksCapabilityException

writeMagicAndWALHeader

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

return the file length after written.

Throws:

java.io.IOException

writeWALTrailerAndMagic

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

Throws:

java.io.IOException

getOutputStreamForCellEncoder

protected abstract java.io.OutputStream getOutputStreamForCellEncoder()