Package org.apache.hadoop.hbase.wal

Class FSHLogProvider

java.lang.Object

org.apache.hadoop.hbase.wal.AbstractWALProvider

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

org.apache.hadoop.hbase.wal.FSHLogProvider

All Implemented Interfaces:

PeerActionListener, WALProvider

@Private
@Evolving
public class FSHLogProvider
extends AbstractFSWALProvider<FSHLog>

A WAL provider that use FSHLog.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	FSHLogProvider.Writer

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

AbstractFSWALProvider.Initializer, AbstractFSWALProvider.WALStartTimeComparator

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

WALProvider.AsyncWriter, WALProvider.WriterBase

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
static final String	WRITER_IMPL

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

DEFAULT_PROVIDER_ID, DEFAULT_SEPARATE_OLDLOGDIR, META_WAL_PROVIDER_ID, SEPARATE_OLDLOGDIR, SPLITTING_EXT, TIMESTAMP_COMPARATOR, wal, WAL_FILE_NAME_DELIMITER

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

abortable, conf, factory, initialized, listeners, logPrefix, providerId

Fields inherited from interface org.apache.hadoop.hbase.replication.regionserver.PeerActionListener

DUMMY

Constructor Summary

Constructors

Constructor	Description
FSHLogProvider()

Method Summary

Modifier and Type	Method	Description
protected WAL	createRemoteWAL(RegionInfo region, org.apache.hadoop.fs.FileSystem remoteFs, org.apache.hadoop.fs.Path remoteWALDir, String prefix, String suffix)
protected FSHLog	createWAL()
static FSHLogProvider.Writer	createWriter(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, boolean overwritable)	Public because of FSHLog.
static FSHLogProvider.Writer	createWriter(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, boolean overwritable, long blocksize)	Public because of FSHLog.
protected void	doInit(org.apache.hadoop.conf.Configuration conf)

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

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

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

close, getLogFileSize, getNumLogFiles, getPeerActionListener, getSyncReplicationPeerIdFromWALName, getWAL, getWALs, init, initWAL, peerSyncReplicationStateChange, setSyncReplicationPeerInfoProvider, shutdown

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 Details

LOG

private static final org.slf4j.Logger LOG

WRITER_IMPL

public static final String WRITER_IMPL

See Also:

• Constant Field Values

Constructor Details

FSHLogProvider

public FSHLogProvider()

Method Details

createWriter

public static FSHLogProvider.Writer createWriter(org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path path,
 boolean overwritable)
                                          throws IOException

Public because of FSHLog. Should be package-private

Parameters:

overwritable - if the created writer can overwrite. For recovered edits, it is true and for WAL it is false. Thus we can distinguish WAL and recovered edits by this.

Throws:

IOException

createWriter

public static FSHLogProvider.Writer createWriter(org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path path,
 boolean overwritable,
 long blocksize)
                                          throws IOException

Public because of FSHLog. Should be package-private

Throws:

IOException

createWAL

protected FSHLog createWAL()
                    throws IOException

Specified by:

createWAL in class AbstractFSWALProvider<FSHLog>

Throws:

IOException

createRemoteWAL

protected WAL createRemoteWAL(RegionInfo region,
 org.apache.hadoop.fs.FileSystem remoteFs,
 org.apache.hadoop.fs.Path remoteWALDir,
 String prefix,
 String suffix)
                       throws IOException

Overrides:

createRemoteWAL in class AbstractFSWALProvider<FSHLog>

Throws:

IOException

doInit

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

Specified by:

doInit in class AbstractFSWALProvider<FSHLog>

Throws:

IOException