org.apache.accumulo.server.zookeeper
Class TransactionWatcher.ZooArbitrator
java.lang.Object
org.apache.accumulo.server.zookeeper.TransactionWatcher.ZooArbitrator
- All Implemented Interfaces:
- TransactionWatcher.Arbitrator
- Enclosing class:
- TransactionWatcher
public static class TransactionWatcher.ZooArbitrator
- extends Object
- implements TransactionWatcher.Arbitrator
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TransactionWatcher.ZooArbitrator
public TransactionWatcher.ZooArbitrator()
transactionAlive
public boolean transactionAlive(String type,
long tid)
throws Exception
- Specified by:
transactionAlive
in interface TransactionWatcher.Arbitrator
- Throws:
Exception
start
public static void start(String type,
long tid)
throws org.apache.zookeeper.KeeperException,
InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
stop
public static void stop(String type,
long tid)
throws org.apache.zookeeper.KeeperException,
InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
cleanup
public static void cleanup(String type,
long tid)
throws org.apache.zookeeper.KeeperException,
InterruptedException
- Throws:
org.apache.zookeeper.KeeperException
InterruptedException
transactionComplete
public boolean transactionComplete(String type,
long tid)
throws Exception
- Specified by:
transactionComplete
in interface TransactionWatcher.Arbitrator
- Throws:
Exception
Copyright © 2013 Apache Accumulo Project. All Rights Reserved.