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) |
Partition |
appendPartition(String db_name,
String table_name,
List<String> part_vals) |
LockResponse |
checkLock(long lockid) |
void |
close() |
void |
commitTxn(long txnid) |
FireEventResponse |
fireListenerEvent(FireEventRequest rqst) |
Partition |
getPartitionWithAuthInfo(String dbName,
String tableName,
List<String> pvals,
String userName,
List<String> groupNames) |
org.apache.hadoop.hive.common.ValidTxnList |
getValidTxns(long currentTxn) |
void |
heartbeat(long txnid,
long lockid) |
boolean |
isCompatibleWith(org.apache.hadoop.conf.Configuration c) |
boolean |
isSameConfObj(org.apache.hadoop.conf.Configuration c) |
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 org.apache.hadoop.hive.common.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 Partition getPartitionWithAuthInfo(String dbName, String tableName, List<String> pvals, String userName, List<String> groupNames) throws MetaException, UnknownTableException, NoSuchObjectException, org.apache.thrift.TException
MetaException
UnknownTableException
NoSuchObjectException
org.apache.thrift.TException
public Partition appendPartition(String db_name, String table_name, List<String> part_vals) throws InvalidObjectException, AlreadyExistsException, MetaException, org.apache.thrift.TException
InvalidObjectException
AlreadyExistsException
MetaException
org.apache.thrift.TException
public FireEventResponse fireListenerEvent(FireEventRequest rqst) throws org.apache.thrift.TException
org.apache.thrift.TException
public void close()
public boolean isSameConfObj(org.apache.hadoop.conf.Configuration c)
public boolean isCompatibleWith(org.apache.hadoop.conf.Configuration c)
Copyright © 2022 The Apache Software Foundation. All rights reserved.