Package org.apache.accumulo.fate

Class AdminUtil<T>

java.lang.Object

org.apache.accumulo.fate.AdminUtil<T>

public class AdminUtil<T>
extends Object

A utility to administer FATE operations

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AdminUtil.FateStatus
static class	AdminUtil.TransactionStatus	FATE transaction status, including lock information.

Constructor Summary

Constructors

Constructor	Description
AdminUtil()	Default constructor
AdminUtil(boolean exitOnError)	Constructor

Method Summary

Modifier and Type	Method	Description
boolean	checkGlobalLock(ZooReaderWriter zk, String path)
void	deleteLocks(ZooReaderWriter zk, String path, String txidStr)
AdminUtil.FateStatus	getStatus(ReadOnlyTStore<T> zs, ZooReader zk, String lockPath, Set<Long> filterTxid, EnumSet<ReadOnlyTStore.TStatus> filterStatus)	Get the FATE transaction status and lock information stored in zookeeper, optionally filtered by transaction id and filter status.
List<AdminUtil.TransactionStatus>	getTransactionStatus(ReadOnlyTStore<T> zs, Set<Long> filterTxid, EnumSet<ReadOnlyTStore.TStatus> filterStatus)	Returns a list of the FATE transactions, optionally filtered by transaction id and status.
boolean	prepDelete(TStore<T> zs, ZooReaderWriter zk, String path, String txidStr)
boolean	prepFail(TStore<T> zs, ZooReaderWriter zk, String path, String txidStr)
void	print(ReadOnlyTStore<T> zs, ZooReader zk, String lockPath)
void	print(ReadOnlyTStore<T> zs, ZooReader zk, String lockPath, Formatter fmt, Set<Long> filterTxid, EnumSet<ReadOnlyTStore.TStatus> filterStatus)

Methods inherited from class java.lang.Object

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

Constructor Detail

AdminUtil

public AdminUtil()

Default constructor

AdminUtil

public AdminUtil(boolean exitOnError)

Constructor

Parameters:

exitOnError - System.exit(1) on error if true

Method Detail

getTransactionStatus

public List<AdminUtil.TransactionStatus> getTransactionStatus(ReadOnlyTStore<T> zs,
                                                              Set<Long> filterTxid,
                                                              EnumSet<ReadOnlyTStore.TStatus> filterStatus)

Returns a list of the FATE transactions, optionally filtered by transaction id and status. This method does not process lock information, if lock information is desired, use getStatus(ReadOnlyTStore, ZooReader, String, Set, EnumSet)

Parameters:

zs - read-only zoostore

filterTxid - filter results to include for provided transaction ids.

filterStatus - filter results to include only provided status types

Returns:

list of FATE transactions that match filter criteria

getStatus

public AdminUtil.FateStatus getStatus(ReadOnlyTStore<T> zs,
                                      ZooReader zk,
                                      String lockPath,
                                      Set<Long> filterTxid,
                                      EnumSet<ReadOnlyTStore.TStatus> filterStatus)
                               throws org.apache.zookeeper.KeeperException,
                                      InterruptedException

Get the FATE transaction status and lock information stored in zookeeper, optionally filtered by transaction id and filter status.

Parameters:

zs - read-only zoostore

zk - zookeeper reader.

lockPath - the zookeeper path for locks

filterTxid - filter results to include for provided transaction ids.

filterStatus - filter results to include only provided status types

Returns:

a summary container of the fate transactions.

Throws:

org.apache.zookeeper.KeeperException - if zookeeper exception occurs

InterruptedException - if process is interrupted.

print

public void print(ReadOnlyTStore<T> zs,
                  ZooReader zk,
                  String lockPath)
           throws org.apache.zookeeper.KeeperException,
                  InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

print

public void print(ReadOnlyTStore<T> zs,
                  ZooReader zk,
                  String lockPath,
                  Formatter fmt,
                  Set<Long> filterTxid,
                  EnumSet<ReadOnlyTStore.TStatus> filterStatus)
           throws org.apache.zookeeper.KeeperException,
                  InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

prepDelete

public boolean prepDelete(TStore<T> zs,
                          ZooReaderWriter zk,
                          String path,
                          String txidStr)

prepFail

public boolean prepFail(TStore<T> zs,
                        ZooReaderWriter zk,
                        String path,
                        String txidStr)

deleteLocks

public void deleteLocks(ZooReaderWriter zk,
                        String path,
                        String txidStr)
                 throws org.apache.zookeeper.KeeperException,
                        InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

checkGlobalLock

public boolean checkGlobalLock(ZooReaderWriter zk,
                               String path)