org.apache.paimon.hive

Class HiveMetastoreClient

java.lang.Object

org.apache.paimon.hive.HiveMetastoreClient

All Implemented Interfaces:

AutoCloseable, MetastoreClient

public class HiveMetastoreClient
extends Object
implements MetastoreClient

MetastoreClient for Hive tables.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HiveMetastoreClient.Factory Factory to create HiveMetastoreClient.

Method Summary

Modifier and Type	Method and Description
void	addPartition(LinkedHashMap<String,String> partition)
void	addPartitions(List<LinkedHashMap<String,String>> partitions)
void	alterPartition(Partition partition)
org.apache.hadoop.hive.metastore.IMetaStoreClient	client()
void	close()
void	dropPartition(LinkedHashMap<String,String> partitionSpec)
void	dropPartitions(List<LinkedHashMap<String,String>> partitions)
void	markPartitionDone(LinkedHashMap<String,String> partitionSpec)

Methods inherited from class java.lang.Object

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

Method Detail

addPartition

public void addPartition(LinkedHashMap<String,String> partition)
                  throws Exception

Specified by:

addPartition in interface MetastoreClient

Throws:

Exception

addPartitions

public void addPartitions(List<LinkedHashMap<String,String>> partitions)
                   throws Exception

Specified by:

addPartitions in interface MetastoreClient

Throws:

Exception

alterPartition

public void alterPartition(Partition partition)
                    throws Exception

Specified by:

alterPartition in interface MetastoreClient

Throws:

Exception

dropPartition

public void dropPartition(LinkedHashMap<String,String> partitionSpec)
                   throws Exception

Specified by:

dropPartition in interface MetastoreClient

Throws:

Exception

dropPartitions

public void dropPartitions(List<LinkedHashMap<String,String>> partitions)
                    throws Exception

Specified by:

dropPartitions in interface MetastoreClient

Throws:

Exception

markPartitionDone

public void markPartitionDone(LinkedHashMap<String,String> partitionSpec)
                       throws Exception

Specified by:

markPartitionDone in interface MetastoreClient

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

client

public org.apache.hadoop.hive.metastore.IMetaStoreClient client()
                                                         throws org.apache.thrift.TException,
                                                                InterruptedException

Throws:

org.apache.thrift.TException

InterruptedException