public class TransactionServiceThriftClient extends Object
Constructor and Description |
---|
TransactionServiceThriftClient(org.apache.thrift.transport.TTransport transport)
Constructor from an existing, connected thrift transport.
|
Modifier and Type | Method and Description |
---|---|
void |
abort(Transaction tx) |
void |
canCommit(Transaction tx,
Collection<byte[]> changeIds) |
Transaction |
checkpoint(Transaction tx) |
void |
close()
close this client.
|
void |
commit(long txId,
long wp) |
int |
getInvalidSize() |
InputStream |
getSnapshotStream() |
boolean |
invalidate(long tx) |
boolean |
isValid() |
void |
pruneNow() |
void |
resetState() |
Transaction |
startLong() |
Transaction |
startLong(String clientId) |
Transaction |
startShort() |
Transaction |
startShort(int timeout) |
Transaction |
startShort(String clientId) |
Transaction |
startShort(String clientId,
int timeout) |
String |
status() |
boolean |
truncateInvalidTx(Set<Long> invalidTxIds) |
boolean |
truncateInvalidTxBefore(long time) |
public TransactionServiceThriftClient(org.apache.thrift.transport.TTransport transport)
transport
- the thrift transport layer. It must already be connectedpublic void close()
public Transaction startLong() throws org.apache.thrift.TException
org.apache.thrift.TException
public Transaction startLong(String clientId) throws org.apache.thrift.TException
org.apache.thrift.TException
public Transaction startShort() throws org.apache.thrift.TException
org.apache.thrift.TException
public Transaction startShort(int timeout) throws org.apache.thrift.TException
org.apache.thrift.TException
public Transaction startShort(String clientId) throws org.apache.thrift.TException
org.apache.thrift.TException
public Transaction startShort(String clientId, int timeout) throws org.apache.thrift.TException
org.apache.thrift.TException
public void canCommit(Transaction tx, Collection<byte[]> changeIds) throws org.apache.thrift.TException, TransactionNotInProgressException, TransactionSizeException, TransactionConflictException
org.apache.thrift.TException
TransactionNotInProgressException
TransactionSizeException
TransactionConflictException
public void commit(long txId, long wp) throws org.apache.thrift.TException, TransactionNotInProgressException, TransactionConflictException
org.apache.thrift.TException
TransactionNotInProgressException
TransactionConflictException
public void abort(Transaction tx) throws org.apache.thrift.TException
org.apache.thrift.TException
public boolean invalidate(long tx) throws org.apache.thrift.TException
org.apache.thrift.TException
public Transaction checkpoint(Transaction tx) throws org.apache.thrift.TException
org.apache.thrift.TException
public InputStream getSnapshotStream() throws org.apache.thrift.TException, TransactionCouldNotTakeSnapshotException
org.apache.thrift.TException
TransactionCouldNotTakeSnapshotException
public String status() throws org.apache.thrift.TException
org.apache.thrift.TException
public void resetState() throws org.apache.thrift.TException
org.apache.thrift.TException
public boolean truncateInvalidTx(Set<Long> invalidTxIds) throws org.apache.thrift.TException
org.apache.thrift.TException
public boolean truncateInvalidTxBefore(long time) throws org.apache.thrift.TException, InvalidTruncateTimeException
org.apache.thrift.TException
InvalidTruncateTimeException
public int getInvalidSize() throws org.apache.thrift.TException
org.apache.thrift.TException
public void pruneNow() throws org.apache.thrift.TException
org.apache.thrift.TException
public boolean isValid()
Copyright © 2018 The Apache Software Foundation. All rights reserved.