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) |
boolean |
canCommit(Transaction tx,
Collection<byte[]> changeIds) |
Transaction |
checkpoint(Transaction tx) |
void |
close()
close this client.
|
boolean |
commit(Transaction tx) |
int |
getInvalidSize() |
InputStream |
getSnapshotStream() |
boolean |
invalidate(long tx) |
boolean |
isValid() |
void |
resetState() |
Transaction |
startLong() |
Transaction |
startShort() |
Transaction |
startShort(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 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 boolean canCommit(Transaction tx, Collection<byte[]> changeIds) throws org.apache.thrift.TException, TransactionNotInProgressException
org.apache.thrift.TException
TransactionNotInProgressException
public boolean commit(Transaction tx) throws org.apache.thrift.TException, TransactionNotInProgressException
org.apache.thrift.TException
TransactionNotInProgressException
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 boolean isValid()
Copyright © 2016 The Apache Software Foundation. All rights reserved.