@InterfaceAudience.Private @InterfaceStability.Evolving public class FSHLogProvider extends AbstractFSWALProvider<FSHLog>
FSHLog
.Modifier and Type | Class and Description |
---|---|
static interface |
FSHLogProvider.Writer |
AbstractFSWALProvider.Initializer, AbstractFSWALProvider.WALStartTimeComparator
WALProvider.AsyncWriter, WALProvider.WriterBase
Modifier and Type | Field and Description |
---|---|
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 |
---|
FSHLogProvider() |
Modifier and Type | Method and 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) |
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
public FSHLogProvider()
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
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.IOException
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
IOException
protected FSHLog createWAL() throws IOException
createWAL
in class AbstractFSWALProvider<FSHLog>
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<FSHLog>
IOException
protected void doInit(org.apache.hadoop.conf.Configuration conf) throws IOException
doInit
in class AbstractFSWALProvider<FSHLog>
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.