org.apache.hadoop.hive.metastore

Class SynchronizedMetaStoreClient

java.lang.Object

org.apache.hadoop.hive.metastore.SynchronizedMetaStoreClient

public final class SynchronizedMetaStoreClient
extends Object

Synchronized MetaStoreClient wrapper

Constructor Summary

Constructors

Constructor and Description
SynchronizedMetaStoreClient(IMetaStoreClient client)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hive.metastore.api.Partition	add_partition(org.apache.hadoop.hive.metastore.api.Partition partition)
void	alter_partition(String dbName, String tblName, org.apache.hadoop.hive.metastore.api.Partition newPart, org.apache.hadoop.hive.metastore.api.EnvironmentContext environmentContext)
org.apache.hadoop.hive.metastore.api.Partition	appendPartition(String db_name, String table_name, List<String> part_vals)
org.apache.hadoop.hive.metastore.api.LockResponse	checkLock(long lockid)
void	close()
void	commitTxn(long txnid)
org.apache.hadoop.hive.metastore.api.FireEventResponse	fireListenerEvent(org.apache.hadoop.hive.metastore.api.FireEventRequest rqst)
org.apache.hadoop.hive.metastore.api.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)
org.apache.hadoop.hive.metastore.api.LockResponse	lock(org.apache.hadoop.hive.metastore.api.LockRequest request)
long	openTxn(String user)
void	rollbackTxn(long txnid)
org.apache.hadoop.hive.metastore.api.ShowLocksResponse	showLocks(org.apache.hadoop.hive.metastore.api.ShowLocksRequest showLocksRequest)
void	unlock(long lockid)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SynchronizedMetaStoreClient

public SynchronizedMetaStoreClient(IMetaStoreClient client)

Method Detail

openTxn

public long openTxn(String user)
             throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

commitTxn

public void commitTxn(long txnid)
               throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

rollbackTxn

public void rollbackTxn(long txnid)
                 throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

heartbeat

public void heartbeat(long txnid,
                      long lockid)
               throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

getValidTxns

public org.apache.hadoop.hive.common.ValidTxnList getValidTxns(long currentTxn)
                                                        throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

lock

public org.apache.hadoop.hive.metastore.api.LockResponse lock(org.apache.hadoop.hive.metastore.api.LockRequest request)
                                                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

add_partition

public org.apache.hadoop.hive.metastore.api.Partition add_partition(org.apache.hadoop.hive.metastore.api.Partition partition)
                                                             throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

alter_partition

public void alter_partition(String dbName,
                            String tblName,
                            org.apache.hadoop.hive.metastore.api.Partition newPart,
                            org.apache.hadoop.hive.metastore.api.EnvironmentContext environmentContext)
                     throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

checkLock

public org.apache.hadoop.hive.metastore.api.LockResponse checkLock(long lockid)
                                                            throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

unlock

public void unlock(long lockid)
            throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

showLocks

public org.apache.hadoop.hive.metastore.api.ShowLocksResponse showLocks(org.apache.hadoop.hive.metastore.api.ShowLocksRequest showLocksRequest)
                                                                 throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

getPartitionWithAuthInfo

public org.apache.hadoop.hive.metastore.api.Partition getPartitionWithAuthInfo(String dbName,
                                                                               String tableName,
                                                                               List<String> pvals,
                                                                               String userName,
                                                                               List<String> groupNames)
                                                                        throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                                               org.apache.hadoop.hive.metastore.api.UnknownTableException,
                                                                               org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                                                               org.apache.thrift.TException

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.hadoop.hive.metastore.api.UnknownTableException

org.apache.hadoop.hive.metastore.api.NoSuchObjectException

org.apache.thrift.TException

appendPartition

public org.apache.hadoop.hive.metastore.api.Partition appendPartition(String db_name,
                                                                      String table_name,
                                                                      List<String> part_vals)
                                                               throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                                                      org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
                                                                      org.apache.hadoop.hive.metastore.api.MetaException,
                                                                      org.apache.thrift.TException

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException

org.apache.hadoop.hive.metastore.api.AlreadyExistsException

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

fireListenerEvent

public org.apache.hadoop.hive.metastore.api.FireEventResponse fireListenerEvent(org.apache.hadoop.hive.metastore.api.FireEventRequest rqst)
                                                                         throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

close

public void close()

isSameConfObj

public boolean isSameConfObj(org.apache.hadoop.conf.Configuration c)

isCompatibleWith

public boolean isCompatibleWith(org.apache.hadoop.conf.Configuration c)