org.apache.accumulo.server.fate
Class Fate<T>

java.lang.Object
  extended by org.apache.accumulo.server.fate.Fate<T>

public class Fate<T>
extends Object

Fault tolerant executor


Constructor Summary
Fate(T environment, TStore<T> store, int numTreads)
           
 
Method Summary
 void delete(long tid)
           
 Exception getException(long tid)
           
 String getReturn(long tid)
           
 void seedTransaction(long tid, Repo<T> repo, boolean autoCleanUp)
           
 long startTransaction()
           
 TStore.TStatus waitForCompletion(long tid)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Fate

public Fate(T environment,
            TStore<T> store,
            int numTreads)
Method Detail

startTransaction

public long startTransaction()

seedTransaction

public void seedTransaction(long tid,
                            Repo<T> repo,
                            boolean autoCleanUp)

waitForCompletion

public TStore.TStatus waitForCompletion(long tid)

delete

public void delete(long tid)

getReturn

public String getReturn(long tid)

getException

public Exception getException(long tid)


Copyright © 2012 The Apache Software Foundation. All Rights Reserved.