org.apache.hadoop.hbase.wal

Class AsyncFSWALProvider

java.lang.Object

org.apache.hadoop.hbase.wal.AbstractFSWALProvider<AsyncFSWAL>

org.apache.hadoop.hbase.wal.AsyncFSWALProvider

All Implemented Interfaces:

WALProvider

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public class AsyncFSWALProvider
extends AbstractFSWALProvider<AsyncFSWAL>

A WAL provider that use AsyncFSWAL.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	AsyncFSWALProvider.AsyncWriter

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

AbstractFSWALProvider.Reader, AbstractFSWALProvider.WALStartTimeComparator

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

WALProvider.Writer, 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
private static org.slf4j.Logger	LOG

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

abortable, 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
AsyncFSWALProvider()

Method Summary

Modifier and Type	Method and Description
static AsyncFSWALProvider.AsyncWriter	createAsyncWriter(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, boolean overwritable, org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup, Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass) Public because of AsyncFSWAL.
static AsyncFSWALProvider.AsyncWriter	createAsyncWriter(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, boolean overwritable, long blocksize, org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup, Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass) Public because of AsyncFSWAL.
protected AsyncFSWAL	createWAL()
protected void	doInit(org.apache.hadoop.conf.Configuration conf)
static boolean	load() Test whether we can load the helper classes for async dfs output.

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

LOG

private static final org.slf4j.Logger LOG

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

AsyncFSWALProvider

public AsyncFSWALProvider()

Method Detail

createWAL

protected AsyncFSWAL createWAL()
                        throws IOException

Specified by:

createWAL in class AbstractFSWALProvider<AsyncFSWAL>

Throws:

IOException

doInit

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

Specified by:

doInit in class AbstractFSWALProvider<AsyncFSWAL>

Throws:

IOException

createAsyncWriter

public static AsyncFSWALProvider.AsyncWriter createAsyncWriter(org.apache.hadoop.conf.Configuration conf,
                                                               org.apache.hadoop.fs.FileSystem fs,
                                                               org.apache.hadoop.fs.Path path,
                                                               boolean overwritable,
                                                               org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup,
                                                               Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass)
                                                        throws IOException

Public because of AsyncFSWAL. Should be package-private

Throws:

IOException

createAsyncWriter

public static AsyncFSWALProvider.AsyncWriter createAsyncWriter(org.apache.hadoop.conf.Configuration conf,
                                                               org.apache.hadoop.fs.FileSystem fs,
                                                               org.apache.hadoop.fs.Path path,
                                                               boolean overwritable,
                                                               long blocksize,
                                                               org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup,
                                                               Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass)
                                                        throws IOException

Public because of AsyncFSWAL. Should be package-private

Throws:

IOException

load

public static boolean load()

Test whether we can load the helper classes for async dfs output.