Package | Description |
---|---|
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.replication.regionserver | |
org.apache.hadoop.hbase.wal |
Modifier and Type | Method and Description |
---|---|
private static void |
HRegionServer.createNewReplicationInstance(org.apache.hadoop.conf.Configuration conf,
HRegionServer server,
org.apache.hadoop.fs.FileSystem walFs,
org.apache.hadoop.fs.Path walDir,
org.apache.hadoop.fs.Path oldWALDir,
WALProvider walProvider)
Load the replication executorService objects, if any
|
void |
ReplicationService.initialize(Server rs,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path logdir,
org.apache.hadoop.fs.Path oldLogDir,
WALProvider walProvider)
Initializes the replication service object.
|
private static <T extends ReplicationService> |
HRegionServer.newReplicationInstance(String classname,
Class<T> xface,
org.apache.hadoop.conf.Configuration conf,
HRegionServer server,
org.apache.hadoop.fs.FileSystem walFs,
org.apache.hadoop.fs.Path logDir,
org.apache.hadoop.fs.Path oldLogDir,
WALProvider walProvider) |
Modifier and Type | Method and Description |
---|---|
void |
Replication.initialize(Server server,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path logDir,
org.apache.hadoop.fs.Path oldLogDir,
WALProvider walProvider) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractFSWALProvider<T extends AbstractFSWAL<?>>
Base class of a WAL Provider that returns a single thread safe WAL that writes to Hadoop FS.
|
class |
AsyncFSWALProvider
A WAL provider that use
AsyncFSWAL . |
(package private) class |
DisabledWALProvider
No-op implementation of
WALProvider used when the WAL is disabled. |
class |
FSHLogProvider
A WAL provider that use
FSHLog . |
class |
RegionGroupingProvider
A WAL Provider that returns a WAL per group of regions.
|
Modifier and Type | Field and Description |
---|---|
private WALProvider |
WALFactory.provider |
Modifier and Type | Field and Description |
---|---|
private ConcurrentMap<String,WALProvider> |
RegionGroupingProvider.cached
A group-provider mapping, make sure one-one rather than many-one mapping
|
(package private) Class<? extends WALProvider> |
WALFactory.Providers.clazz |
private AtomicReference<WALProvider> |
WALFactory.metaProvider |
private Class<? extends WALProvider> |
RegionGroupingProvider.providerClass |
Modifier and Type | Method and Description |
---|---|
(package private) WALProvider |
WALFactory.createProvider(Class<? extends WALProvider> clazz,
String providerId) |
private WALProvider |
RegionGroupingProvider.createProvider(String group) |
(package private) WALProvider |
WALFactory.getMetaProvider() |
WALProvider |
WALFactory.getMetaWALProvider() |
(package private) WALProvider |
WALFactory.getProvider(String key,
String defaultValue,
String providerId)
instantiate a provider from a config property.
|
WALProvider |
WALFactory.getWALProvider() |
Modifier and Type | Method and Description |
---|---|
Class<? extends WALProvider> |
WALFactory.getProviderClass(String key,
String defaultValue) |
Modifier and Type | Method and Description |
---|---|
(package private) WALProvider |
WALFactory.createProvider(Class<? extends WALProvider> clazz,
String providerId) |
Constructor and Description |
---|
Providers(Class<? extends WALProvider> clazz) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.