com.splicemachine.si.impl.data

Class StripedTxnLifecycleStore

java.lang.Object

com.splicemachine.si.impl.data.StripedTxnLifecycleStore

All Implemented Interfaces:

TxnLifecycleStore

public class StripedTxnLifecycleStore
extends java.lang.Object
implements TxnLifecycleStore

Constructor Summary

Constructors

Constructor and Description
StripedTxnLifecycleStore(int numPartitions, TxnPartition baseStore, ServerControl serverControl, TimestampSource timestampSource)

Method Summary

Modifier and Type	Method and Description
void	beginTransaction(com.splicemachine.si.coprocessor.TxnMessage.TxnInfo txn)
long	commitTransaction(long txnId)
void	elevateTransaction(long txnId, byte[] destTable)
long[]	getActiveTransactionIds(byte[] destTable, long startId, long endId)
Source<com.splicemachine.si.coprocessor.TxnMessage.Txn>	getActiveTransactions(byte[] destTable, long startId, long endId)
com.splicemachine.si.coprocessor.TxnMessage.Txn	getOldTransaction(long txnId)
com.splicemachine.si.coprocessor.TxnMessage.TaskId	getTaskId(long txnId)
com.splicemachine.si.coprocessor.TxnMessage.Txn	getTransaction(long txnId)
boolean	keepAlive(long txnId)
void	rollbackSubtransactions(long txnId, long[] subIds)
void	rollbackTransaction(long txnId)
void	rollbackTransactionsAfter(long txnId)

Methods inherited from class java.lang.Object

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

Constructor Detail

StripedTxnLifecycleStore

public StripedTxnLifecycleStore(int numPartitions,
                                TxnPartition baseStore,
                                ServerControl serverControl,
                                TimestampSource timestampSource)

Method Detail

beginTransaction

public void beginTransaction(com.splicemachine.si.coprocessor.TxnMessage.TxnInfo txn)
                      throws java.io.IOException

Specified by:

beginTransaction in interface TxnLifecycleStore

Throws:

java.io.IOException

elevateTransaction

public void elevateTransaction(long txnId,
                               byte[] destTable)
                        throws java.io.IOException

Specified by:

elevateTransaction in interface TxnLifecycleStore

Throws:

java.io.IOException

commitTransaction

public long commitTransaction(long txnId)
                       throws java.io.IOException

Specified by:

commitTransaction in interface TxnLifecycleStore

Throws:

java.io.IOException

rollbackTransaction

public void rollbackTransaction(long txnId)
                         throws java.io.IOException

Specified by:

rollbackTransaction in interface TxnLifecycleStore

Throws:

java.io.IOException

rollbackSubtransactions

public void rollbackSubtransactions(long txnId,
                                    long[] subIds)
                             throws java.io.IOException

Specified by:

rollbackSubtransactions in interface TxnLifecycleStore

Throws:

java.io.IOException

keepAlive

public boolean keepAlive(long txnId)
                  throws java.io.IOException

Specified by:

keepAlive in interface TxnLifecycleStore

Throws:

java.io.IOException

getOldTransaction

public com.splicemachine.si.coprocessor.TxnMessage.Txn getOldTransaction(long txnId)
                                                                  throws java.io.IOException

Specified by:

getOldTransaction in interface TxnLifecycleStore

Throws:

java.io.IOException

getTransaction

public com.splicemachine.si.coprocessor.TxnMessage.Txn getTransaction(long txnId)
                                                               throws java.io.IOException

Specified by:

getTransaction in interface TxnLifecycleStore

Throws:

java.io.IOException

getTaskId

public com.splicemachine.si.coprocessor.TxnMessage.TaskId getTaskId(long txnId)
                                                             throws java.io.IOException

Specified by:

getTaskId in interface TxnLifecycleStore

Throws:

java.io.IOException

getActiveTransactionIds

public long[] getActiveTransactionIds(byte[] destTable,
                                      long startId,
                                      long endId)
                               throws java.io.IOException

Specified by:

getActiveTransactionIds in interface TxnLifecycleStore

Throws:

java.io.IOException

getActiveTransactions

public Source<com.splicemachine.si.coprocessor.TxnMessage.Txn> getActiveTransactions(byte[] destTable,
                                                                                     long startId,
                                                                                     long endId)
                                                                              throws java.io.IOException

Specified by:

getActiveTransactions in interface TxnLifecycleStore

Throws:

java.io.IOException

rollbackTransactionsAfter

public void rollbackTransactionsAfter(long txnId)
                               throws java.io.IOException

Specified by:

rollbackTransactionsAfter in interface TxnLifecycleStore

Throws:

java.io.IOException