@InterfaceAudience.Private public class RegionGroupingProvider extends Object implements WALProvider
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 |
---|---|
static interface |
RegionGroupingProvider.RegionGroupingStrategy
Map identifiers to a group number.
|
WALProvider.Writer
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_DELEGATE_PROVIDER |
static String |
DEFAULT_REGION_GROUPING_STRATEGY |
static String |
DELEGATE_PROVIDER
delegate provider for WAL creation/roll/close
|
static String |
REGION_GROUPING_STRATEGY |
Constructor and Description |
---|
RegionGroupingProvider() |
Modifier and Type | Method and Description |
---|---|
void |
close()
shutdown utstanding WALs and clean up any persisted state.
|
long |
getLogFileSize()
Get size of the log files this provider is managing
|
long |
getNumLogFiles()
Get number of the log files this provider is managing
|
WAL |
getWAL(byte[] identifier,
byte[] namespace) |
List<WAL> |
getWALs() |
void |
init(WALFactory factory,
org.apache.hadoop.conf.Configuration conf,
List<WALActionsListener> listeners,
String providerId)
Set up the provider to create wals.
|
void |
shutdown()
persist outstanding WALs to storage and stop accepting new appends.
|
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
public void init(WALFactory factory, org.apache.hadoop.conf.Configuration conf, List<WALActionsListener> listeners, String providerId) throws IOException
WALProvider
init
in interface WALProvider
factory
- factory that made us may not be nullconf
- may not be nulllisteners
- may be nullproviderId
- differentiate between providers from one factory. may be nullIOException
public List<WAL> getWALs() throws IOException
getWALs
in interface WALProvider
IOException
public WAL getWAL(byte[] identifier, byte[] namespace) throws IOException
getWAL
in interface WALProvider
identifier
- may not be null. contents will not be altered.namespace
- could be null, and will use default namespace if nullIOException
public void shutdown() throws IOException
WALProvider
shutdown
in interface WALProvider
IOException
public void close() throws IOException
WALProvider
close
in interface WALProvider
IOException
public long getNumLogFiles()
WALProvider
getNumLogFiles
in interface WALProvider
public long getLogFileSize()
WALProvider
getLogFileSize
in interface WALProvider
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.