org.apache.hadoop.hbase.wal

Class BoundedRegionGroupingProvider

java.lang.Object

org.apache.hadoop.hbase.wal.BoundedRegionGroupingProvider

All Implemented Interfaces:

WALProvider

@InterfaceAudience.Private
public class BoundedRegionGroupingProvider
extends Object

A WAL Provider that pre-creates N WALProviders and then limits our grouping strategy to them. Control the number of delegate providers via "hbase.wal.regiongrouping.numgroups." Control the choice of delegate provider implementation and the grouping strategy the same as RegionGroupingProvider.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	org.apache.hadoop.hbase.wal.RegionGroupingProvider.RegionGroupingStrategy Map identifiers to a group number.

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

WALProvider.Writer

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentMap<byte[],WALProvider>	cached
protected org.apache.hadoop.hbase.wal.RegionGroupingProvider.RegionGroupingStrategy	strategy

Constructor Summary

Constructors

Constructor and Description
BoundedRegionGroupingProvider()

Method Summary

Modifier and Type	Method and Description
void	close() shutdown utstanding WALs and clean up any persisted state.
static long	getLogFileSize(WALFactory walFactory) iff the given WALFactory is using the BoundedRegionGroupingProvider for meta and/or non-meta, count the size of files (rolled and active).
static long	getNumLogFiles(WALFactory walFactory) iff the given WALFactory is using the BoundedRegionGroupingProvider for meta and/or non-meta, count the number of files (rolled and active).
WAL	getWAL(byte[] identifier)
void	init(WALFactory factory, 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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

cached

protected final ConcurrentMap<byte[],WALProvider> cached

strategy

protected org.apache.hadoop.hbase.wal.RegionGroupingProvider.RegionGroupingStrategy strategy

Constructor Detail

BoundedRegionGroupingProvider

public BoundedRegionGroupingProvider()

Method Detail

init

public void init(WALFactory factory,
                 Configuration conf,
                 List<WALActionsListener> listeners,
                 String providerId)
          throws IOException

Description copied from interface: WALProvider

Set up the provider to create wals. will only be called once per instance.

Specified by:

init in interface WALProvider

Parameters:

factory - factory that made us may not be null

conf - may not be null

listeners - may be null

providerId - differentiate between providers from one factory. may be null

Throws:

IOException

shutdown

public void shutdown()
              throws IOException

Description copied from interface: WALProvider

persist outstanding WALs to storage and stop accepting new appends. This method serves as shorthand for sending a sync to every WAL provided by a given implementation. Those WALs will also stop accepting new writes.

Specified by:

shutdown in interface WALProvider

Throws:

IOException

close

public void close()
           throws IOException

Description copied from interface: WALProvider

shutdown utstanding WALs and clean up any persisted state. Call this method only when you will not need to replay any of the edits to the WALs from this provider. After this call completes, the underlying resources should have been reclaimed.

Specified by:

close in interface WALProvider

Throws:

IOException

getNumLogFiles

public static long getNumLogFiles(WALFactory walFactory)

iff the given WALFactory is using the BoundedRegionGroupingProvider for meta and/or non-meta, count the number of files (rolled and active). if either of them isn't, count 0 for that provider.

Parameters:

walFactory - may not be null.

getLogFileSize

public static long getLogFileSize(WALFactory walFactory)

iff the given WALFactory is using the BoundedRegionGroupingProvider for meta and/or non-meta, count the size of files (rolled and active). if either of them isn't, count 0 for that provider.

Parameters:

walFactory - may not be null.

getWAL

public WAL getWAL(byte[] identifier)
           throws IOException

Specified by:

getWAL in interface WALProvider

Parameters:

identifier - may not be null. contents will not be altered.

Returns:

a WAL for writing entries for the given region.

Throws:

IOException