org.tikv.txn

Class TwoPhaseCommitter

java.lang.Object

org.tikv.txn.TwoPhaseCommitter

All Implemented Interfaces:

AutoCloseable

public class TwoPhaseCommitter
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor and Description
TwoPhaseCommitter(TiSession session, long startTime)
TwoPhaseCommitter(TiSession session, long startTime, long lockTTL)
TwoPhaseCommitter(TiSession session, long startTime, long lockTTL, ExecutorService executorService)

Method Summary

Modifier and Type	Method and Description
void	close()
void	commitPrimaryKey(BackOffer backOffer, byte[] key, long commitTs) 2pc - commit primary key
void	commitSecondaryKeys(Iterator<ByteWrapper> keys, long commitTs, int commitBackOfferMS) 2pc - commit secondary keys
void	prewritePrimaryKey(BackOffer backOffer, byte[] primaryKey, byte[] value) 2pc - prewrite primary key
void	prewriteSecondaryKeys(byte[] primaryKey, Iterator<BytePairWrapper> pairs, int maxBackOfferMS) 2pc - prewrite secondary keys

Methods inherited from class java.lang.Object

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

Constructor Detail

TwoPhaseCommitter

public TwoPhaseCommitter(TiSession session,
                         long startTime)

TwoPhaseCommitter

public TwoPhaseCommitter(TiSession session,
                         long startTime,
                         long lockTTL)

TwoPhaseCommitter

public TwoPhaseCommitter(TiSession session,
                         long startTime,
                         long lockTTL,
                         ExecutorService executorService)

Method Detail

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

prewritePrimaryKey

public void prewritePrimaryKey(BackOffer backOffer,
                               byte[] primaryKey,
                               byte[] value)
                        throws TiBatchWriteException

2pc - prewrite primary key

Parameters:

backOffer -

primaryKey -

value -

Throws:

TiBatchWriteException

commitPrimaryKey

public void commitPrimaryKey(BackOffer backOffer,
                             byte[] key,
                             long commitTs)
                      throws TiBatchWriteException

2pc - commit primary key

Parameters:

backOffer -

key -

Throws:

TiBatchWriteException

prewriteSecondaryKeys

public void prewriteSecondaryKeys(byte[] primaryKey,
                                  Iterator<BytePairWrapper> pairs,
                                  int maxBackOfferMS)
                           throws TiBatchWriteException

2pc - prewrite secondary keys

Parameters:

primaryKey -

pairs -

Throws:

TiBatchWriteException

commitSecondaryKeys

public void commitSecondaryKeys(Iterator<ByteWrapper> keys,
                                long commitTs,
                                int commitBackOfferMS)
                         throws TiBatchWriteException

2pc - commit secondary keys

Parameters:

keys -

commitTs -

Throws:

TiBatchWriteException