public final class SynchronizedMetaStoreClient extends Object
Constructor and Description |
---|
SynchronizedMetaStoreClient(IMetaStoreClient client) |
Modifier and Type | Method and Description |
---|---|
Partition |
add_partition(Partition partition) |
void |
alter_partition(String dbName,
String tblName,
Partition newPart,
EnvironmentContext environmentContext) |
LockResponse |
checkLock(long lockid) |
void |
close() |
void |
commitTxn(long txnid) |
ValidTxnList |
getValidTxns(long currentTxn) |
void |
heartbeat(long txnid,
long lockid) |
LockResponse |
lock(LockRequest request) |
long |
openTxn(String user) |
void |
rollbackTxn(long txnid) |
ShowLocksResponse |
showLocks(ShowLocksRequest showLocksRequest) |
void |
unlock(long lockid) |
public SynchronizedMetaStoreClient(IMetaStoreClient client)
public long openTxn(String user) throws org.apache.thrift.TException
org.apache.thrift.TException
public void commitTxn(long txnid) throws org.apache.thrift.TException
org.apache.thrift.TException
public void rollbackTxn(long txnid) throws org.apache.thrift.TException
org.apache.thrift.TException
public void heartbeat(long txnid, long lockid) throws org.apache.thrift.TException
org.apache.thrift.TException
public ValidTxnList getValidTxns(long currentTxn) throws org.apache.thrift.TException
org.apache.thrift.TException
public LockResponse lock(LockRequest request) throws org.apache.thrift.TException
org.apache.thrift.TException
public Partition add_partition(Partition partition) throws org.apache.thrift.TException
org.apache.thrift.TException
public void alter_partition(String dbName, String tblName, Partition newPart, EnvironmentContext environmentContext) throws org.apache.thrift.TException
org.apache.thrift.TException
public LockResponse checkLock(long lockid) throws org.apache.thrift.TException
org.apache.thrift.TException
public void unlock(long lockid) throws org.apache.thrift.TException
org.apache.thrift.TException
public ShowLocksResponse showLocks(ShowLocksRequest showLocksRequest) throws org.apache.thrift.TException
org.apache.thrift.TException
public void close()
Copyright © 2021 The Apache Software Foundation. All rights reserved.