org.apache.accumulo.server.log

Class WalStateManager

java.lang.Object

org.apache.accumulo.server.log.WalStateManager

public class WalStateManager
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	WalStateManager.WalMarkerException
static class	WalStateManager.WalState

Field Summary

Fields

Modifier and Type	Field and Description
static String	ZWALS

Constructor Summary

Constructors

Constructor and Description
WalStateManager(Instance instance, ZooReaderWriter zoo)

Method Summary

Methods

Modifier and Type	Method and Description
void	addNewWalMarker(TServerInstance tsi, org.apache.hadoop.fs.Path path)
void	closeWal(TServerInstance instance, org.apache.hadoop.fs.Path path)
void	forget(TServerInstance instance)
Map<TServerInstance,List<UUID>>	getAllMarkers()
Map<org.apache.hadoop.fs.Path,WalStateManager.WalState>	getAllState()
List<org.apache.hadoop.fs.Path>	getWalsInUse(TServerInstance tsi)
void	initWalMarker(TServerInstance tsi)
void	removeWalMarker(TServerInstance instance, UUID uuid)
Pair<WalStateManager.WalState,org.apache.hadoop.fs.Path>	state(TServerInstance instance, UUID uuid)
void	walUnreferenced(TServerInstance tsi, org.apache.hadoop.fs.Path path)

Methods inherited from class java.lang.Object

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

Field Detail

ZWALS

public static final String ZWALS

See Also:

Constant Field Values

Constructor Detail

WalStateManager

public WalStateManager(Instance instance,
               ZooReaderWriter zoo)

Method Detail

initWalMarker

public void initWalMarker(TServerInstance tsi)
                   throws WalStateManager.WalMarkerException

Throws:

WalStateManager.WalMarkerException

addNewWalMarker

public void addNewWalMarker(TServerInstance tsi,
                   org.apache.hadoop.fs.Path path)
                     throws WalStateManager.WalMarkerException

Throws:

WalStateManager.WalMarkerException

walUnreferenced

public void walUnreferenced(TServerInstance tsi,
                   org.apache.hadoop.fs.Path path)
                     throws WalStateManager.WalMarkerException

Throws:

WalStateManager.WalMarkerException

getWalsInUse

public List<org.apache.hadoop.fs.Path> getWalsInUse(TServerInstance tsi)
                                             throws WalStateManager.WalMarkerException

Throws:

WalStateManager.WalMarkerException

getAllMarkers

public Map<TServerInstance,List<UUID>> getAllMarkers()
                                              throws WalStateManager.WalMarkerException

Throws:

WalStateManager.WalMarkerException

state

public Pair<WalStateManager.WalState,org.apache.hadoop.fs.Path> state(TServerInstance instance,
                                                             UUID uuid)
                                                               throws WalStateManager.WalMarkerException

Throws:

WalStateManager.WalMarkerException

getAllState

public Map<org.apache.hadoop.fs.Path,WalStateManager.WalState> getAllState()
                                                                    throws WalStateManager.WalMarkerException

Throws:

WalStateManager.WalMarkerException

removeWalMarker

public void removeWalMarker(TServerInstance instance,
                   UUID uuid)
                     throws WalStateManager.WalMarkerException

Throws:

WalStateManager.WalMarkerException

forget

public void forget(TServerInstance instance)
            throws WalStateManager.WalMarkerException

Throws:

WalStateManager.WalMarkerException

closeWal

public void closeWal(TServerInstance instance,
            org.apache.hadoop.fs.Path path)
              throws WalStateManager.WalMarkerException

Throws:

WalStateManager.WalMarkerException