org.apache.hadoop.hbase.regionserver.wal

Class TestAsyncFSWALRollStuck.TestAsyncWriter

java.lang.Object

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

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

org.apache.hadoop.hbase.regionserver.wal.TestAsyncFSWALRollStuck.TestAsyncWriter

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.wal.AsyncFSWALProvider.AsyncWriter, org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter, org.apache.hadoop.hbase.wal.WALProvider.WriterBase

Enclosing class:

TestAsyncFSWALRollStuck

public static final class TestAsyncFSWALRollStuck.TestAsyncWriter
extends org.apache.hadoop.hbase.regionserver.wal.AsyncProtobufLogWriter

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
TestAsyncWriter(org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup, Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Long>	sync(boolean forceSync)

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

append, close, closeOutputIfNecessary, getOutput, getOutputStreamForCellEncoder, getSyncedLength, getWriterClassName, initOutput, writeMagicAndWALHeader, writeWALTrailerAndMagic

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

buildSecureWALHeader, buildWALHeader, getLength, 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.AsyncFSWALProvider.AsyncWriter

init

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

getLength

Constructor Detail

TestAsyncWriter

public TestAsyncWriter(org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup,
                       Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass)

Method Detail

sync

public CompletableFuture<Long> sync(boolean forceSync)

Specified by:

sync in interface org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter

Overrides:

sync in class org.apache.hadoop.hbase.regionserver.wal.AsyncProtobufLogWriter