org.apache.hawq.pxf.plugins.hive.utilities

Class HiveUtilities

java.lang.Object

org.apache.hawq.pxf.plugins.hive.utilities.HiveUtilities

public class HiveUtilities
extends java.lang.Object

Class containing helper functions connecting and interacting with Hive.

Constructor Summary

Constructors

Constructor and Description
HiveUtilities()

Method Summary

Modifier and Type	Method and Description
static Metadata.Item	extractTableFromName(java.lang.String qualifiedName) Extracts the db_name and table_name from the qualifiedName.
static java.util.List<Metadata.Item>	extractTablesFromPattern(org.apache.hadoop.hive.metastore.HiveMetaStoreClient client, java.lang.String pattern) Extracts the db_name(s) and table_name(s) corresponding to the given pattern.
static org.apache.hadoop.hive.metastore.api.Table	getHiveTable(org.apache.hadoop.hive.metastore.HiveMetaStoreClient client, Metadata.Item itemName)
static org.apache.hadoop.hive.metastore.HiveMetaStoreClient	initHiveClient() Initializes the HiveMetaStoreClient Uses classpath configuration files to locate the MetaStore
static Metadata.Field	mapHiveType(org.apache.hadoop.hive.metastore.api.FieldSchema hiveColumn) Checks if hive type is supported, and if so return its matching HAWQ type.

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveUtilities

public HiveUtilities()

Method Detail

initHiveClient

public static org.apache.hadoop.hive.metastore.HiveMetaStoreClient initHiveClient()

Initializes the HiveMetaStoreClient Uses classpath configuration files to locate the MetaStore

Returns:

initialized client

getHiveTable

public static org.apache.hadoop.hive.metastore.api.Table getHiveTable(org.apache.hadoop.hive.metastore.HiveMetaStoreClient client,
                                                                      Metadata.Item itemName)
                                                               throws java.lang.Exception

Throws:

java.lang.Exception

mapHiveType

public static Metadata.Field mapHiveType(org.apache.hadoop.hive.metastore.api.FieldSchema hiveColumn)
                                  throws UnsupportedTypeException

Checks if hive type is supported, and if so return its matching HAWQ type. Unsupported types will result in an exception.
The supported mappings are:

• tinyint -> int2
• smallint -> int2
• int -> int4
• bigint -> int8
• boolean -> bool
• float -> float4
• double -> float8
• string -> text
• binary -> bytea
• timestamp -> timestamp
• date -> date
• decimal(precision, scale) -> numeric(precision, scale)
• varchar(size) -> varchar(size)
• char(size) -> bpchar(size)

Parameters:

hiveColumn - hive column schema

Returns:

field with mapped HAWQ type and modifiers

Throws:

UnsupportedTypeException - if the column type is not supported

extractTableFromName

public static Metadata.Item extractTableFromName(java.lang.String qualifiedName)

Extracts the db_name and table_name from the qualifiedName. qualifiedName is the Hive table name that the user enters in the CREATE EXTERNAL TABLE statement or when querying HCatalog table. It can be either table_name or db_name.table_name.

Parameters:

qualifiedName - Hive table name

Returns:

Metadata.Item object holding the full table name

extractTablesFromPattern

public static java.util.List<Metadata.Item> extractTablesFromPattern(org.apache.hadoop.hive.metastore.HiveMetaStoreClient client,
                                                                     java.lang.String pattern)

Extracts the db_name(s) and table_name(s) corresponding to the given pattern. pattern is the Hive table name or pattern that the user enters in the CREATE EXTERNAL TABLE statement or when querying HCatalog table. It can be either table_name_pattern or db_name_pattern.table_name_pattern.

Parameters:

client - Hivemetastore client

pattern - Hive table name or pattern

Returns:

list of Metadata.Item objects holding the full table name