@InterfaceAudience.Private @InterfaceStability.Evolving public class AsyncFSWALProvider extends AbstractFSWALProvider<AsyncFSWAL>
AsyncFSWAL
.Modifier and Type | Class and Description |
---|---|
static interface |
AsyncFSWALProvider.AsyncWriter |
AbstractFSWALProvider.Initializer, AbstractFSWALProvider.WALStartTimeComparator
WALProvider.Writer, WALProvider.WriterBase
Modifier and Type | Field and Description |
---|---|
protected Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> |
channelClass
Protected visibility for used in tests.
|
protected org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup |
eventLoopGroup
Protected visibility for used in tests.
|
private static org.slf4j.Logger |
LOG |
static String |
WRITER_IMPL |
DEFAULT_PROVIDER_ID, DEFAULT_SEPARATE_OLDLOGDIR, META_WAL_PROVIDER_ID, SEPARATE_OLDLOGDIR, SPLITTING_EXT, TIMESTAMP_COMPARATOR, wal, WAL_FILE_NAME_DELIMITER
abortable, conf, factory, initialized, listeners, logPrefix, providerId
DUMMY
Constructor and Description |
---|
AsyncFSWALProvider() |
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,
StreamSlowMonitor monitor)
Public because of AsyncFSWAL.
|
protected WAL |
createRemoteWAL(RegionInfo region,
org.apache.hadoop.fs.FileSystem remoteFs,
org.apache.hadoop.fs.Path remoteWALDir,
String prefix,
String suffix) |
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.
|
addWALActionsListener, close0, doInit, extractFileNumFromWAL, findArchivedLog, getArchivedWALFiles, getCurrentFileName, getLogFileSize, getLogFileSize0, getNumLogFiles0, getNumRolledLogFiles, getServerNameFromWALDirectoryName, getServerNameFromWALDirectoryName, getTimestamp, getWAL0, getWALArchiveDirectoryName, getWALDirectoryName, getWALFiles, getWALPrefixFromWALName, getWALs0, isArchivedLogFile, isMetaFile, isMetaFile, parseServerNameFromWALName, recoverLease, requestLogRoll, shutdown0, validateWALFilename
close, getLogFileSize, getNumLogFiles, getPeerActionListener, getSyncReplicationPeerIdFromWALName, getWAL, getWALs, init, initWAL, peerSyncReplicationStateChange, setSyncReplicationPeerInfoProvider, shutdown
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getWALFileLengthProvider
private static final org.slf4j.Logger LOG
public static final String WRITER_IMPL
protected org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup
protected Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass
public AsyncFSWALProvider()
protected AsyncFSWAL createWAL() throws IOException
createWAL
in class AbstractFSWALProvider<AsyncFSWAL>
IOException
protected WAL createRemoteWAL(RegionInfo region, org.apache.hadoop.fs.FileSystem remoteFs, org.apache.hadoop.fs.Path remoteWALDir, String prefix, String suffix) throws IOException
createRemoteWAL
in class AbstractFSWALProvider<AsyncFSWAL>
IOException
protected void doInit(org.apache.hadoop.conf.Configuration conf) throws IOException
doInit
in class AbstractFSWALProvider<AsyncFSWAL>
IOException
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
IOException
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, StreamSlowMonitor monitor) throws IOException
IOException
public static boolean load()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.