@InterfaceAudience.Private public class RegionGroupingProvider extends AbstractWALProvider
DELEGATE_PROVIDER
Region grouping is handled via RegionGroupingProvider.RegionGroupingStrategy
and can
be configured via the property "hbase.wal.regiongrouping.strategy". Current strategy choices are
Modifier and Type | Class and Description |
---|---|
(package private) static class |
RegionGroupingProvider.IdentityGroupingStrategy |
static interface |
RegionGroupingProvider.RegionGroupingStrategy
Map identifiers to a group number.
|
(package private) static class |
RegionGroupingProvider.Strategies
Maps between configuration names for strategies and implementation classes.
|
WALProvider.AsyncWriter, WALProvider.Writer, WALProvider.WriterBase
Modifier and Type | Field and Description |
---|---|
private ConcurrentMap<String,WALProvider> |
cached
A group-provider mapping, make sure one-one rather than many-one mapping
|
private KeyLocker<String> |
createLock |
static String |
DEFAULT_DELEGATE_PROVIDER |
static String |
DEFAULT_REGION_GROUPING_STRATEGY |
static String |
DELEGATE_PROVIDER
delegate provider for WAL creation/roll/close, but not support multiwal
|
private static org.slf4j.Logger |
LOG |
private static String |
META_WAL_GROUP_NAME |
private Class<? extends WALProvider> |
providerClass |
static String |
REGION_GROUPING_STRATEGY |
private RegionGroupingProvider.RegionGroupingStrategy |
strategy |
abortable, conf, factory, initialized, listeners, logPrefix, providerId, WAL_FILE_NAME_DELIMITER
DUMMY
Constructor and Description |
---|
RegionGroupingProvider() |
Modifier and Type | Method and Description |
---|---|
protected void |
close0() |
private WALProvider |
createProvider(String group) |
protected WAL |
createRemoteWAL(RegionInfo region,
org.apache.hadoop.fs.FileSystem remoteFs,
org.apache.hadoop.fs.Path remoteWALDir,
String prefix,
String suffix) |
protected void |
doInit(WALFactory factory,
org.apache.hadoop.conf.Configuration conf,
String providerId) |
protected long |
getLogFileSize0() |
protected long |
getNumLogFiles0() |
(package private) RegionGroupingProvider.RegionGroupingStrategy |
getStrategy(org.apache.hadoop.conf.Configuration conf,
String key,
String defaultValue)
instantiate a strategy from a config property.
|
private WAL |
getWAL(String group) |
protected WAL |
getWAL0(RegionInfo region) |
private WALProvider |
getWALProvider(RegionInfo region) |
protected List<WAL> |
getWALs0() |
protected void |
shutdown0() |
addWALActionsListener, 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 REGION_GROUPING_STRATEGY
public static final String DEFAULT_REGION_GROUPING_STRATEGY
public static final String DELEGATE_PROVIDER
public static final String DEFAULT_DELEGATE_PROVIDER
private static final String META_WAL_GROUP_NAME
private final ConcurrentMap<String,WALProvider> cached
private final KeyLocker<String> createLock
private RegionGroupingProvider.RegionGroupingStrategy strategy
private Class<? extends WALProvider> providerClass
public RegionGroupingProvider()
RegionGroupingProvider.RegionGroupingStrategy getStrategy(org.apache.hadoop.conf.Configuration conf, String key, String defaultValue) throws IOException
IOException
protected void doInit(WALFactory factory, org.apache.hadoop.conf.Configuration conf, String providerId) throws IOException
doInit
in class AbstractWALProvider
IOException
private WALProvider createProvider(String group) throws IOException
IOException
private WALProvider getWALProvider(RegionInfo region) throws IOException
IOException
protected WAL getWAL0(RegionInfo region) throws IOException
getWAL0
in class AbstractWALProvider
IOException
protected List<WAL> getWALs0()
getWALs0
in class AbstractWALProvider
private WAL getWAL(String group) throws IOException
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 AbstractWALProvider
IOException
protected void shutdown0() throws IOException
shutdown0
in class AbstractWALProvider
IOException
protected void close0() throws IOException
close0
in class AbstractWALProvider
IOException
protected long getNumLogFiles0()
getNumLogFiles0
in class AbstractWALProvider
protected long getLogFileSize0()
getLogFileSize0
in class AbstractWALProvider
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.