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(BinaryRow partition)
void	addPartition(LinkedHashMap<String,String> partitionSpec)
org.apache.hadoop.hive.metastore.IMetaStoreClient	client()
void	close()
void	deletePartition(LinkedHashMap<String,String> partitionSpec)
void	markDone(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(BinaryRow partition)
                  throws Exception

Specified by:

addPartition in interface MetastoreClient

Throws:

Exception

addPartition

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

Specified by:

addPartition in interface MetastoreClient

Throws:

Exception

deletePartition

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

Specified by:

deletePartition in interface MetastoreClient

Throws:

Exception

markDone

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

Specified by:

markDone 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