public class TransactionServiceThriftHandler extends Object implements TTransactionServer.Iface, RPCServiceHandler
Constructor and Description |
---|
TransactionServiceThriftHandler(TransactionManager txManager) |
Modifier and Type | Method and Description |
---|---|
void |
abortTx(TTransaction tx) |
TBoolean |
canCommitTx(TTransaction tx,
Set<ByteBuffer> changes) |
TTransaction |
checkpoint(TTransaction originalTx) |
TBoolean |
commitTx(TTransaction tx) |
void |
destroy() |
ByteBuffer |
getSnapshot() |
void |
init() |
boolean |
invalidateTx(long tx) |
int |
invalidTxSize() |
void |
resetState() |
TTransaction |
startLong() |
TTransaction |
startLongClientId(String clientId) |
TTransaction |
startShort() |
TTransaction |
startShortClientId(String clientId) |
TTransaction |
startShortTimeout(int timeout) |
TTransaction |
startShortWithClientIdAndTimeOut(String clientId,
int timeout) |
TTransaction |
startShortWithTimeout(int timeout) |
String |
status() |
TBoolean |
truncateInvalidTx(Set<Long> txns) |
TBoolean |
truncateInvalidTxBefore(long time) |
public TransactionServiceThriftHandler(TransactionManager txManager)
public TTransaction startLong() throws org.apache.thrift.TException
startLong
in interface TTransactionServer.Iface
org.apache.thrift.TException
public TTransaction startShort() throws org.apache.thrift.TException
startShort
in interface TTransactionServer.Iface
org.apache.thrift.TException
public TTransaction startLongClientId(String clientId) throws org.apache.thrift.TException
startLongClientId
in interface TTransactionServer.Iface
org.apache.thrift.TException
public TTransaction startShortTimeout(int timeout) throws org.apache.thrift.TException
startShortTimeout
in interface TTransactionServer.Iface
org.apache.thrift.TException
public TTransaction startShortClientId(String clientId) throws org.apache.thrift.TException
startShortClientId
in interface TTransactionServer.Iface
org.apache.thrift.TException
public TTransaction startShortWithClientIdAndTimeOut(String clientId, int timeout) throws org.apache.thrift.TException
startShortWithClientIdAndTimeOut
in interface TTransactionServer.Iface
org.apache.thrift.TException
public TTransaction startShortWithTimeout(int timeout) throws org.apache.thrift.TException
startShortWithTimeout
in interface TTransactionServer.Iface
org.apache.thrift.TException
public TBoolean canCommitTx(TTransaction tx, Set<ByteBuffer> changes) throws org.apache.thrift.TException
canCommitTx
in interface TTransactionServer.Iface
org.apache.thrift.TException
public TBoolean commitTx(TTransaction tx) throws org.apache.thrift.TException
commitTx
in interface TTransactionServer.Iface
org.apache.thrift.TException
public void abortTx(TTransaction tx) throws org.apache.thrift.TException
abortTx
in interface TTransactionServer.Iface
org.apache.thrift.TException
public boolean invalidateTx(long tx) throws org.apache.thrift.TException
invalidateTx
in interface TTransactionServer.Iface
org.apache.thrift.TException
public ByteBuffer getSnapshot() throws org.apache.thrift.TException
getSnapshot
in interface TTransactionServer.Iface
org.apache.thrift.TException
public void resetState() throws org.apache.thrift.TException
resetState
in interface TTransactionServer.Iface
org.apache.thrift.TException
public String status() throws org.apache.thrift.TException
status
in interface TTransactionServer.Iface
org.apache.thrift.TException
public TBoolean truncateInvalidTx(Set<Long> txns) throws org.apache.thrift.TException
truncateInvalidTx
in interface TTransactionServer.Iface
org.apache.thrift.TException
public TBoolean truncateInvalidTxBefore(long time) throws org.apache.thrift.TException
truncateInvalidTxBefore
in interface TTransactionServer.Iface
org.apache.thrift.TException
public int invalidTxSize() throws org.apache.thrift.TException
invalidTxSize
in interface TTransactionServer.Iface
org.apache.thrift.TException
public TTransaction checkpoint(TTransaction originalTx) throws org.apache.thrift.TException
checkpoint
in interface TTransactionServer.Iface
org.apache.thrift.TException
public void init() throws Exception
init
in interface RPCServiceHandler
Exception
public void destroy() throws Exception
destroy
in interface RPCServiceHandler
Exception
Copyright © 2017 The Apache Software Foundation. All rights reserved.