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)
void	addPartitions(List<BinaryRow> partitions)
void	addPartitionsSpec(List<LinkedHashMap<String,String>> partitionSpecsList)
void	alterPartition(LinkedHashMap<String,String> partitionSpec, Map<String,String> parameters, long modifyTime)
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

addPartitions

public void addPartitions(List<BinaryRow> partitions)
                   throws Exception

Specified by:

addPartitions in interface MetastoreClient

Throws:

Exception

addPartition

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

Specified by:

addPartition in interface MetastoreClient

Throws:

Exception

addPartitionsSpec

public void addPartitionsSpec(List<LinkedHashMap<String,String>> partitionSpecsList)
                       throws Exception

Specified by:

addPartitionsSpec in interface MetastoreClient

Throws:

Exception

alterPartition

public void alterPartition(LinkedHashMap<String,String> partitionSpec,
                           Map<String,String> parameters,
                           long modifyTime)
                    throws Exception

Specified by:

alterPartition 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