org.apache.hadoop.hbase.regionserver.wal

Class AsyncProtobufLogWriter

java.lang.Object

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

org.apache.hadoop.hbase.regionserver.wal.AsyncProtobufLogWriter

Direct Known Subclasses:

SecureAsyncProtobufLogWriter

public class AsyncProtobufLogWriter
extends AbstractProtobufLogWriter

AsyncWriter for protobuf-based WAL.

Field Summary

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
AsyncProtobufLogWriter(EventLoopGroup eventLoopGroup, java.lang.Class<? extends Channel> channelClass)

Method Summary

Modifier and Type	Method and Description
void	append(Entry entry)
void	close()
AsyncFSOutput	getOutput()
protected java.io.OutputStream	getOutputStreamForCellEncoder()
protected java.lang.String	getWriterClassName()
protected void	initOutput(FileSystem fs, Path path, boolean overwritable, int bufferSize, short replication, long blockSize)
java.util.concurrent.CompletableFuture<java.lang.Long>	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, init, initAfterHeader, secureInitAfterHeader, setEncryptor, writeWALTrailer

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncProtobufLogWriter

public AsyncProtobufLogWriter(EventLoopGroup eventLoopGroup,
                              java.lang.Class<? extends Channel> channelClass)

Method Detail

getWriterClassName

protected java.lang.String getWriterClassName()

Overrides:

getWriterClassName in class AbstractProtobufLogWriter

append

public void append(Entry entry)

sync

public java.util.concurrent.CompletableFuture<java.lang.Long> sync()

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

getOutput

public AsyncFSOutput getOutput()

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

writeWALTrailerAndMagic

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

Specified by:

writeWALTrailerAndMagic in class AbstractProtobufLogWriter

Throws:

java.io.IOException

getOutputStreamForCellEncoder

protected java.io.OutputStream getOutputStreamForCellEncoder()

Specified by:

getOutputStreamForCellEncoder in class AbstractProtobufLogWriter