org.apache.flink.connectors.hive

Class HiveTablePartition

java.lang.Object

org.apache.flink.connectors.hive.HiveTablePartition

All Implemented Interfaces:

Serializable

@PublicEvolving
public class HiveTablePartition
extends Object
implements Serializable

A class that describes a partition of a Hive table. And it represents the whole table if table is not partitioned.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HiveTablePartition(org.apache.hadoop.hive.metastore.api.StorageDescriptor storageDescriptor, Map<String,String> partitionSpec, Properties tableProps) Creates a HiveTablePartition to describe a hive table or partition.
HiveTablePartition(org.apache.hadoop.hive.metastore.api.StorageDescriptor storageDescriptor, Properties tableProps) Creates a HiveTablePartition to describe a hive table.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
Map<String,String>	getPartitionSpec()
org.apache.hadoop.hive.metastore.api.StorageDescriptor	getStorageDescriptor()
Properties	getTableProps()
int	hashCode()
static HiveTablePartition	ofPartition(HiveConf hiveConf, String hiveVersion, String dbName, String tableName, LinkedHashMap<String,String> partitionSpec) Creates a HiveTablePartition to represent a hive partition.
static HiveTablePartition	ofTable(HiveConf hiveConf, String hiveVersion, String dbName, String tableName) Creates a HiveTablePartition to represent a hive table.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

HiveTablePartition

public HiveTablePartition(org.apache.hadoop.hive.metastore.api.StorageDescriptor storageDescriptor,
                          Properties tableProps)

Creates a HiveTablePartition to describe a hive table.

Parameters:

storageDescriptor - SD of the hive table

tableProps - properties of the hive table

HiveTablePartition

public HiveTablePartition(org.apache.hadoop.hive.metastore.api.StorageDescriptor storageDescriptor,
                          Map<String,String> partitionSpec,
                          Properties tableProps)

Creates a HiveTablePartition to describe a hive table or partition.

Parameters:

storageDescriptor - SD of the hive table or partition

partitionSpec - the spec for the hive partition, and should be empty if the HiveTablePartition is to describe a hive table

tableProps - properties of the hive table or partition

Method Detail

getStorageDescriptor

public org.apache.hadoop.hive.metastore.api.StorageDescriptor getStorageDescriptor()

getPartitionSpec

public Map<String,String> getPartitionSpec()

getTableProps

public Properties getTableProps()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

ofTable

public static HiveTablePartition ofTable(HiveConf hiveConf,
                                         @Nullable
                                         String hiveVersion,
                                         String dbName,
                                         String tableName)

Creates a HiveTablePartition to represent a hive table.

Parameters:

hiveConf - the HiveConf used to connect to HMS

hiveVersion - the version of hive in use, if it's null the version will be automatically detected

dbName - name of the database

tableName - name of the table

ofPartition

public static HiveTablePartition ofPartition(HiveConf hiveConf,
                                             @Nullable
                                             String hiveVersion,
                                             String dbName,
                                             String tableName,
                                             LinkedHashMap<String,String> partitionSpec)

Creates a HiveTablePartition to represent a hive partition.

Parameters:

hiveConf - the HiveConf used to connect to HMS

hiveVersion - the version of hive in use, if it's null the version will be automatically detected

dbName - name of the database

tableName - name of the table

partitionSpec - map from each partition column to its value. The map should contain exactly all the partition columns and in the order in which the partition columns are defined