org.apache.hadoop.hbase.wal

Class TestAsyncFSWALCorruptionDueToDanglingByteBuffer.PauseWALProvider

java.lang.Object

org.apache.hadoop.hbase.wal.AbstractFSWALProvider<TestAsyncFSWALCorruptionDueToDanglingByteBuffer.PauseWAL>

org.apache.hadoop.hbase.wal.TestAsyncFSWALCorruptionDueToDanglingByteBuffer.PauseWALProvider

All Implemented Interfaces:

org.apache.hadoop.hbase.wal.WALProvider

Enclosing class:

TestAsyncFSWALCorruptionDueToDanglingByteBuffer

public static final class TestAsyncFSWALCorruptionDueToDanglingByteBuffer.PauseWALProvider
extends org.apache.hadoop.hbase.wal.AbstractFSWALProvider<TestAsyncFSWALCorruptionDueToDanglingByteBuffer.PauseWAL>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.wal.AbstractFSWALProvider

org.apache.hadoop.hbase.wal.AbstractFSWALProvider.Reader

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.wal.WALProvider

org.apache.hadoop.hbase.wal.WALProvider.AsyncWriter, org.apache.hadoop.hbase.wal.WALProvider.Writer, org.apache.hadoop.hbase.wal.WALProvider.WriterBase

Field Summary

Fields

Modifier and Type	Field and Description
private Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel>	channelClass
private org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup	eventLoopGroup

Fields inherited from class org.apache.hadoop.hbase.wal.AbstractFSWALProvider

conf, DEFAULT_PROVIDER_ID, DEFAULT_SEPARATE_OLDLOGDIR, factory, initialized, listeners, logPrefix, META_WAL_PROVIDER_ID, providerId, SEPARATE_OLDLOGDIR, SPLITTING_EXT, wal, WAL_FILE_NAME_DELIMITER

Constructor Summary

Constructors

Constructor and Description
PauseWALProvider()

Method Summary

Modifier and Type	Method and Description
protected TestAsyncFSWALCorruptionDueToDanglingByteBuffer.PauseWAL	createWAL()
protected void	doInit(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class org.apache.hadoop.hbase.wal.AbstractFSWALProvider

addWALActionsListener, close, extractFileNumFromWAL, getArchivedLogPath, getCurrentFileName, getLogFileSize, getLogFileSize, getNumLogFiles, getNumRolledLogFiles, getServerNameFromWALDirectoryName, getServerNameFromWALDirectoryName, getWAL, getWALArchiveDirectoryName, getWALDirectoryName, getWALPrefixFromWALName, getWALs, init, isArchivedLogFile, isMetaFile, isMetaFile, openReader, requestLogRoll, shutdown, validateWALFilename

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.WALProvider

getWALFileLengthProvider

Field Detail

eventLoopGroup

private org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup

channelClass

private Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass

Constructor Detail

PauseWALProvider

public PauseWALProvider()

Method Detail

createWAL

protected TestAsyncFSWALCorruptionDueToDanglingByteBuffer.PauseWAL createWAL()
                                                                      throws IOException

Specified by:

createWAL in class org.apache.hadoop.hbase.wal.AbstractFSWALProvider<TestAsyncFSWALCorruptionDueToDanglingByteBuffer.PauseWAL>

Throws:

IOException

doInit

protected void doInit(org.apache.hadoop.conf.Configuration conf)
               throws IOException

Specified by:

doInit in class org.apache.hadoop.hbase.wal.AbstractFSWALProvider<TestAsyncFSWALCorruptionDueToDanglingByteBuffer.PauseWAL>

Throws:

IOException