org.apache.hive.hcatalog.api

Class HCatClientHMSImpl

java.lang.Object

org.apache.hive.hcatalog.api.HCatClient

org.apache.hive.hcatalog.api.HCatClientHMSImpl

public class HCatClientHMSImpl
extends HCatClient

The HCatClientHMSImpl is the Hive Metastore client based implementation of HCatClient.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hive.hcatalog.api.HCatClient

HCatClient.DropDBMode

Field Summary

Fields inherited from class org.apache.hive.hcatalog.api.HCatClient

HCAT_CLIENT_IMPL_CLASS

Constructor Summary

Constructors

Constructor and Description
HCatClientHMSImpl()

Method Summary

Methods

Modifier and Type	Method and Description
void	addPartition(HCatAddPartitionDesc partInfo) Adds the partition.
int	addPartitions(List<HCatAddPartitionDesc> partInfoList) Adds a list of partitions.
int	addPartitionSpec(HCatPartitionSpec partitionSpec) Adds partitions using HCatPartitionSpec.
void	cancelDelegationToken(String tokenStrForm) Cancel delegation token.
void	close() Close the hcatalog client.
void	createDatabase(HCatCreateDBDesc dbInfo) Creates the database.
void	createTable(HCatCreateTableDesc createTableDesc) Creates the table.
void	createTableLike(String dbName, String existingTblName, String newTableName, boolean ifNotExists, boolean isExternal, String location) Creates the table like an existing table.
HCatPartition	deserializePartition(String hcatPartitionStringRep) Deserializer for an HCatPartition.
List<HCatPartition>	deserializePartitions(List<String> hcatPartitionStringReps) Deserializer for a list of HCatPartition strings.
HCatPartitionSpec	deserializePartitionSpec(List<String> hcatPartitionSpecStrings) Deserializer for HCatPartitionSpec.
HCatTable	deserializeTable(String hcatTableStringRep) Deserializer for HCatTable.
void	dropDatabase(String dbName, boolean ifExists, HCatClient.DropDBMode mode) Drops a database.
void	dropPartitions(String dbName, String tableName, Map<String,String> partitionSpec, boolean ifExists) Drops partition(s) that match the specified (and possibly partial) partition specification.
void	dropPartitions(String dbName, String tableName, Map<String,String> partitionSpec, boolean ifExists, boolean deleteData) Drops partition(s) that match the specified (and possibly partial) partition specification.
void	dropTable(String dbName, String tableName, boolean ifExists) Drop table.
String	getConfVal(String key, String defaultVal) Fetch configuration value on conf that the HCatClient is instantiated against.
long	getCurrentNotificationEventId() Get the most recently used notification id.
HCatDatabase	getDatabase(String dbName) Gets the database.
String	getDelegationToken(String owner, String renewerKerberosPrincipalName) Gets the delegation token.
String	getMessageBusTopicName(String dbName, String tableName) Retrieve Message-bus topic for a table.
List<HCatNotificationEvent>	getNextNotification(long lastEventId, int maxEvents, IMetaStoreClient.NotificationFilter filter) Get a list of notifications
HCatPartition	getPartition(String dbName, String tableName, Map<String,String> partitionSpec) Gets the partition.
List<HCatPartition>	getPartitions(String dbName, String tblName) Gets all the partitions.
List<HCatPartition>	getPartitions(String dbName, String tblName, Map<String,String> partitionSpec) Gets all the partitions that match the specified (and possibly partial) partition specification.
HCatPartitionSpec	getPartitionSpecs(String dbName, String tableName, int maxPartitions) Gets partitions in terms of generic HCatPartitionSpec instances.
HCatPartitionSpec	getPartitionSpecs(String dbName, String tableName, Map<String,String> partitionSelector, int maxPartitions) Gets partitions in terms of generic HCatPartitionSpec instances.
Iterator<ReplicationTask>	getReplicationTasks(long lastEventId, int maxEvents, String dbName, String tableName) Get an iterator that iterates over a list of replication tasks needed to replicate all the events that have taken place for a given db/table.
HCatTable	getTable(String dbName, String tableName) Gets the table.
boolean	isPartitionMarkedForEvent(String dbName, String tblName, Map<String,String> partKVs, PartitionEventType eventType) Checks if a partition is marked for event.
List<String>	listDatabaseNamesByPattern(String pattern) Get all existing databases that match the given pattern.
List<HCatPartition>	listPartitionsByFilter(String dbName, String tblName, String filter) List partitions by filter.
HCatPartitionSpec	listPartitionSpecsByFilter(String dbName, String tblName, String filter, int maxPartitions) List partitions by filter, but as HCatPartitionSpecs.
List<String>	listTableNamesByPattern(String dbName, String tablePattern) Returns all existing tables from the specified database which match the given pattern.
void	markPartitionForEvent(String dbName, String tblName, Map<String,String> partKVs, PartitionEventType eventType) Mark partition for event.
void	renameTable(String dbName, String oldName, String newName) Renames a table.
long	renewDelegationToken(String tokenStrForm) Renew delegation token.
String	serializePartition(HCatPartition hcatPartition) Serializer for HCatPartition.
List<String>	serializePartitions(List<HCatPartition> hcatPartitions) Serializer for a list of HCatPartition.
List<String>	serializePartitionSpec(HCatPartitionSpec partitionSpec) Serializer for HCatPartitionSpec.
String	serializeTable(HCatTable hcatTable) Serializer for HCatTable.
void	updateTableSchema(String dbName, String tableName, HCatTable newTableDefinition) Updates the Table's whole schema (including column schema, I/O Formats, SerDe definitions, etc.)
void	updateTableSchema(String dbName, String tableName, List<HCatFieldSchema> columnSchema) Updates the Table's column schema to the specified definition.

Methods inherited from class org.apache.hive.hcatalog.api.HCatClient

create

Methods inherited from class java.lang.Object

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

Constructor Detail

HCatClientHMSImpl

public HCatClientHMSImpl()

Method Detail

listDatabaseNamesByPattern

public List<String> listDatabaseNamesByPattern(String pattern)
                                        throws HCatException

Description copied from class: HCatClient

Get all existing databases that match the given pattern. The matching occurs as per Java regular expressions

Specified by:

listDatabaseNamesByPattern in class HCatClient

Parameters:

pattern - java re pattern

Returns:

list of database names

Throws:

HCatException

getDatabase

public HCatDatabase getDatabase(String dbName)
                         throws HCatException

Description copied from class: HCatClient

Gets the database.

Specified by:

getDatabase in class HCatClient

Parameters:

dbName - The name of the database.

Returns:

An instance of HCatDatabaseInfo.

Throws:

HCatException

createDatabase

public void createDatabase(HCatCreateDBDesc dbInfo)
                    throws HCatException

Description copied from class: HCatClient

Creates the database.

Specified by:

createDatabase in class HCatClient

Parameters:

dbInfo - An instance of HCatCreateDBDesc.

Throws:

HCatException

dropDatabase

public void dropDatabase(String dbName,
                boolean ifExists,
                HCatClient.DropDBMode mode)
                  throws HCatException

Description copied from class: HCatClient

Drops a database.

Specified by:

dropDatabase in class HCatClient

Parameters:

dbName - The name of the database to delete.

ifExists - Hive returns an error if the database specified does not exist, unless ifExists is set to true.

mode - This is set to either "restrict" or "cascade". Restrict will remove the schema if all the tables are empty. Cascade removes everything including data and definitions.

Throws:

HCatException

listTableNamesByPattern

public List<String> listTableNamesByPattern(String dbName,
                                   String tablePattern)
                                     throws HCatException

Description copied from class: HCatClient

Returns all existing tables from the specified database which match the given pattern. The matching occurs as per Java regular expressions.

Specified by:

listTableNamesByPattern in class HCatClient

Parameters:

dbName - The name of the DB (to be searched)

tablePattern - The regex for the table-name

Returns:

list of table names

Throws:

HCatException

getTable

public HCatTable getTable(String dbName,
                 String tableName)
                   throws HCatException

Description copied from class: HCatClient

Gets the table.

Specified by:

getTable in class HCatClient

Parameters:

dbName - The name of the database.

tableName - The name of the table.

Returns:

An instance of HCatTableInfo.

Throws:

HCatException

createTable

public void createTable(HCatCreateTableDesc createTableDesc)
                 throws HCatException

Description copied from class: HCatClient

Creates the table.

Specified by:

createTable in class HCatClient

Parameters:

createTableDesc - An instance of HCatCreateTableDesc class.

Throws:

HCatException

updateTableSchema

public void updateTableSchema(String dbName,
                     String tableName,
                     List<HCatFieldSchema> columnSchema)
                       throws HCatException

Description copied from class: HCatClient

Updates the Table's column schema to the specified definition.

Specified by:

updateTableSchema in class HCatClient

Parameters:

dbName - The name of the database.

tableName - The name of the table.

columnSchema - The (new) definition of the column schema (i.e. list of fields).

Throws:

HCatException

updateTableSchema

public void updateTableSchema(String dbName,
                     String tableName,
                     HCatTable newTableDefinition)
                       throws HCatException

Description copied from class: HCatClient

Updates the Table's whole schema (including column schema, I/O Formats, SerDe definitions, etc.)

Specified by:

updateTableSchema in class HCatClient

Parameters:

dbName - The name of the database.

tableName - The name of the table.

newTableDefinition - The (new) definition of the table.

Throws:

HCatException

createTableLike

public void createTableLike(String dbName,
                   String existingTblName,
                   String newTableName,
                   boolean ifNotExists,
                   boolean isExternal,
                   String location)
                     throws HCatException

Description copied from class: HCatClient

Creates the table like an existing table.

Specified by:

createTableLike in class HCatClient

Parameters:

dbName - The name of the database.

existingTblName - The name of the existing table.

newTableName - The name of the new table.

ifNotExists - If true, then error related to already table existing is skipped.

isExternal - Set to "true", if table has be created at a different location other than default.

location - The location for the table.

Throws:

HCatException

dropTable

public void dropTable(String dbName,
             String tableName,
             boolean ifExists)
               throws HCatException

Description copied from class: HCatClient

Drop table.

Specified by:

dropTable in class HCatClient

Parameters:

dbName - The name of the database.

tableName - The name of the table.

ifExists - Hive returns an error if the database specified does not exist, unless ifExists is set to true.

Throws:

HCatException

renameTable

public void renameTable(String dbName,
               String oldName,
               String newName)
                 throws HCatException

Description copied from class: HCatClient

Renames a table.

Specified by:

renameTable in class HCatClient

Parameters:

dbName - The name of the database.

oldName - The name of the table to be renamed.

newName - The new name of the table.

Throws:

HCatException

getPartitions

public List<HCatPartition> getPartitions(String dbName,
                                String tblName)
                                  throws HCatException

Description copied from class: HCatClient

Gets all the partitions.

Specified by:

getPartitions in class HCatClient

Parameters:

dbName - The name of the database.

tblName - The name of the table.

Returns:

A list of partitions.

Throws:

HCatException

getPartitions

public List<HCatPartition> getPartitions(String dbName,
                                String tblName,
                                Map<String,String> partitionSpec)
                                  throws HCatException

Description copied from class: HCatClient

Gets all the partitions that match the specified (and possibly partial) partition specification. A partial partition-specification is one where not all partition-keys have associated values. For example, for a table ('myDb.myTable') with 2 partition keys (dt string, region string), if for each dt ('20120101', '20120102', etc.) there can exist 3 regions ('us', 'uk', 'in'), then, 1. Complete partition spec: getPartitions('myDb', 'myTable', {dt='20120101', region='us'}) would return 1 partition. 2. Partial partition spec: getPartitions('myDb', 'myTable', {dt='20120101'}) would return all 3 partitions, with dt='20120101' (i.e. region = 'us', 'uk' and 'in').

Specified by:

getPartitions in class HCatClient

Parameters:

dbName - The name of the database.

tblName - The name of the table.

partitionSpec - The partition specification. (Need not include all partition keys.)

Returns:

A list of partitions.

Throws:

HCatException

getPartitionSpecs

@InterfaceAudience.LimitedPrivate(value="Hive")
@InterfaceStability.Evolving
public HCatPartitionSpec getPartitionSpecs(String dbName,
                                                                                                    String tableName,
                                                                                                    int maxPartitions)
                                    throws HCatException

Description copied from class: HCatClient

Gets partitions in terms of generic HCatPartitionSpec instances.

Specified by:

getPartitionSpecs in class HCatClient

Throws:

HCatException

getPartitionSpecs

public HCatPartitionSpec getPartitionSpecs(String dbName,
                                  String tableName,
                                  Map<String,String> partitionSelector,
                                  int maxPartitions)
                                    throws HCatException

Description copied from class: HCatClient

Gets partitions in terms of generic HCatPartitionSpec instances.

Specified by:

getPartitionSpecs in class HCatClient

Throws:

HCatException

getPartition

public HCatPartition getPartition(String dbName,
                         String tableName,
                         Map<String,String> partitionSpec)
                           throws HCatException

Description copied from class: HCatClient

Gets the partition.

Specified by:

getPartition in class HCatClient

Parameters:

dbName - The database name.

tableName - The table name.

partitionSpec - The partition specification, {[col_name,value],[col_name2,value2]}. All partition-key-values must be specified.

Returns:

An instance of HCatPartitionInfo.

Throws:

HCatException

addPartition

public void addPartition(HCatAddPartitionDesc partInfo)
                  throws HCatException

Description copied from class: HCatClient

Adds the partition.

Specified by:

addPartition in class HCatClient

Parameters:

partInfo - An instance of HCatAddPartitionDesc.

Throws:

HCatException

dropPartitions

public void dropPartitions(String dbName,
                  String tableName,
                  Map<String,String> partitionSpec,
                  boolean ifExists,
                  boolean deleteData)
                    throws HCatException

Description copied from class: HCatClient

Drops partition(s) that match the specified (and possibly partial) partition specification. A partial partition-specification is one where not all partition-keys have associated values. For example, for a table ('myDb.myTable') with 2 partition keys (dt string, region string), if for each dt ('20120101', '20120102', etc.) there can exist 3 regions ('us', 'uk', 'in'), then, 1. Complete partition spec: dropPartitions('myDb', 'myTable', {dt='20120101', region='us'}) would drop 1 partition. 2. Partial partition spec: dropPartitions('myDb', 'myTable', {dt='20120101'}) would drop all 3 partitions, with dt='20120101' (i.e. region = 'us', 'uk' and 'in').

Specified by:

dropPartitions in class HCatClient

Parameters:

dbName - The database name.

tableName - The table name.

partitionSpec - The partition specification, {[col_name,value],[col_name2,value2]}.

ifExists - Hive returns an error if the partition specified does not exist, unless ifExists is set to true.

deleteData - Whether to delete the underlying data.

Throws:

HCatException

dropPartitions

public void dropPartitions(String dbName,
                  String tableName,
                  Map<String,String> partitionSpec,
                  boolean ifExists)
                    throws HCatException

Description copied from class: HCatClient

Drops partition(s) that match the specified (and possibly partial) partition specification. A partial partition-specification is one where not all partition-keys have associated values. For example, for a table ('myDb.myTable') with 2 partition keys (dt string, region string), if for each dt ('20120101', '20120102', etc.) there can exist 3 regions ('us', 'uk', 'in'), then, 1. Complete partition spec: dropPartitions('myDb', 'myTable', {dt='20120101', region='us'}) would drop 1 partition. 2. Partial partition spec: dropPartitions('myDb', 'myTable', {dt='20120101'}) would drop all 3 partitions, with dt='20120101' (i.e. region = 'us', 'uk' and 'in').

Specified by:

dropPartitions in class HCatClient

Parameters:

dbName - The database name.

tableName - The table name.

partitionSpec - The partition specification, {[col_name,value],[col_name2,value2]}.

ifExists - Hive returns an error if the partition specified does not exist, unless ifExists is set to true.

Throws:

HCatException

listPartitionsByFilter

public List<HCatPartition> listPartitionsByFilter(String dbName,
                                         String tblName,
                                         String filter)
                                           throws HCatException

Description copied from class: HCatClient

List partitions by filter.

Specified by:

listPartitionsByFilter in class HCatClient

Parameters:

dbName - The database name.

tblName - The table name.

filter - The filter string, for example "part1 = \"p1_abc\" and part2 <= "\p2_test\"". Filtering can be done only on string partition keys.

Returns:

list of partitions

Throws:

HCatException

listPartitionSpecsByFilter

@InterfaceAudience.LimitedPrivate(value="Hive")
@InterfaceStability.Evolving
public HCatPartitionSpec listPartitionSpecsByFilter(String dbName,
                                                                                                             String tblName,
                                                                                                             String filter,
                                                                                                             int maxPartitions)
                                             throws HCatException

Description copied from class: HCatClient

List partitions by filter, but as HCatPartitionSpecs.

Specified by:

listPartitionSpecsByFilter in class HCatClient

Throws:

HCatException

markPartitionForEvent

public void markPartitionForEvent(String dbName,
                         String tblName,
                         Map<String,String> partKVs,
                         PartitionEventType eventType)
                           throws HCatException

Description copied from class: HCatClient

Mark partition for event.

Specified by:

markPartitionForEvent in class HCatClient

Parameters:

dbName - The database name.

tblName - The table name.

partKVs - the key-values associated with the partition.

eventType - the event type

Throws:

HCatException

isPartitionMarkedForEvent

public boolean isPartitionMarkedForEvent(String dbName,
                                String tblName,
                                Map<String,String> partKVs,
                                PartitionEventType eventType)
                                  throws HCatException

Description copied from class: HCatClient

Checks if a partition is marked for event.

Specified by:

isPartitionMarkedForEvent in class HCatClient

Parameters:

dbName - the db name

tblName - the table name

partKVs - the key-values associated with the partition.

eventType - the event type

Returns:

true, if is partition marked for event

Throws:

HCatException

getDelegationToken

public String getDelegationToken(String owner,
                        String renewerKerberosPrincipalName)
                          throws HCatException

Description copied from class: HCatClient

Gets the delegation token.

Specified by:

getDelegationToken in class HCatClient

Parameters:

owner - the owner

renewerKerberosPrincipalName - the renewer kerberos principal name

Returns:

the delegation token

Throws:

HCatException

renewDelegationToken

public long renewDelegationToken(String tokenStrForm)
                          throws HCatException

Description copied from class: HCatClient

Renew delegation token.

Specified by:

renewDelegationToken in class HCatClient

Parameters:

tokenStrForm - the token string

Returns:

the new expiration time

Throws:

HCatException

cancelDelegationToken

public void cancelDelegationToken(String tokenStrForm)
                           throws HCatException

Description copied from class: HCatClient

Cancel delegation token.

Specified by:

cancelDelegationToken in class HCatClient

Parameters:

tokenStrForm - the token string

Throws:

HCatException

getConfVal

public String getConfVal(String key,
                String defaultVal)

Description copied from class: HCatClient

Fetch configuration value on conf that the HCatClient is instantiated against. We do not want to expose the conf itself via a getConf(), because we do not want it modifiable after instantiation of the HCatClient, but modules that get called from HCatClient often need to know about how HCatClient is configured, so we want a read-only interface for it.

Specified by:

getConfVal in class HCatClient

Parameters:

key - keyname to look up

defaultVal - default value to furnish in case the key does not exist

Returns:

value for given key, and defaultVal if key is not present in conf

close

public void close()
           throws HCatException

Description copied from class: HCatClient

Close the hcatalog client.

Specified by:

close in class HCatClient

Throws:

HCatException

addPartitions

public int addPartitions(List<HCatAddPartitionDesc> partInfoList)
                  throws HCatException

Description copied from class: HCatClient

Adds a list of partitions.

Specified by:

addPartitions in class HCatClient

Parameters:

partInfoList - A list of HCatAddPartitionDesc.

Returns:

The number of partitions added.

Throws:

HCatException

addPartitionSpec

@InterfaceAudience.LimitedPrivate(value="Hive")
@InterfaceStability.Evolving
public int addPartitionSpec(HCatPartitionSpec partitionSpec)
                     throws HCatException

Description copied from class: HCatClient

Adds partitions using HCatPartitionSpec.

Specified by:

addPartitionSpec in class HCatClient

Parameters:

partitionSpec - The HCatPartitionSpec representing the set of partitions added.

Returns:

The number of partitions added.

Throws:

HCatException - On failure to add partitions.

getMessageBusTopicName

public String getMessageBusTopicName(String dbName,
                            String tableName)
                              throws HCatException

Description copied from class: HCatClient

Retrieve Message-bus topic for a table.

Specified by:

getMessageBusTopicName in class HCatClient

Parameters:

dbName - The name of the DB.

tableName - The name of the table.

Returns:

Topic-name for the message-bus on which messages will be sent for the specified table. By default, this is set to .. Returns null when not set.

Throws:

HCatException

getReplicationTasks

public Iterator<ReplicationTask> getReplicationTasks(long lastEventId,
                                            int maxEvents,
                                            String dbName,
                                            String tableName)
                                              throws HCatException

Description copied from class: HCatClient

Get an iterator that iterates over a list of replication tasks needed to replicate all the events that have taken place for a given db/table.

Specified by:

getReplicationTasks in class HCatClient

Parameters:

lastEventId - : The last event id that was processed for this reader. The returned replication tasks will start from this point forward

maxEvents - : Maximum number of events to consider for generating the replication tasks. If < 1, then all available events will be considered.

dbName - : The database name for which we're interested in the events for.

tableName - : The table name for which we're interested in the events for - if null, then this function will behave as if it were running at a db level.

Returns:

an iterator over a list of replication events that can be processed one by one.

Throws:

HCatException

getNextNotification

public List<HCatNotificationEvent> getNextNotification(long lastEventId,
                                              int maxEvents,
                                              IMetaStoreClient.NotificationFilter filter)
                                                throws HCatException

Description copied from class: HCatClient

Get a list of notifications

Specified by:

getNextNotification in class HCatClient

Parameters:

lastEventId - The last event id that was consumed by this reader. The returned notifications will start at the next eventId available this eventId that matches the filter.

maxEvents - Maximum number of events to return. If < 1, then all available events will be returned.

filter - Filter to determine if message should be accepted. If null, then all available events up to maxEvents will be returned.

Returns:

list of notifications, sorted by eventId. It is guaranteed that the events are in the order that the operations were done on the database.

Throws:

HCatException

getCurrentNotificationEventId

public long getCurrentNotificationEventId()
                                   throws HCatException

Description copied from class: HCatClient

Get the most recently used notification id.

Specified by:

getCurrentNotificationEventId in class HCatClient

Returns:

Throws:

HCatException

serializeTable

public String serializeTable(HCatTable hcatTable)
                      throws HCatException

Description copied from class: HCatClient

Serializer for HCatTable.

Specified by:

serializeTable in class HCatClient

Parameters:

hcatTable - The HCatTable to be serialized into string form

Returns:

String representation of the HCatTable.

Throws:

HCatException

deserializeTable

public HCatTable deserializeTable(String hcatTableStringRep)
                           throws HCatException

Description copied from class: HCatClient

Deserializer for HCatTable.

Specified by:

deserializeTable in class HCatClient

Parameters:

hcatTableStringRep - The String representation of an HCatTable, presumably retrieved from HCatClient.serializeTable(HCatTable)

Returns:

HCatTable reconstructed from the string throws HCatException, on failure to deserialize.

Throws:

HCatException

serializePartition

public String serializePartition(HCatPartition hcatPartition)
                          throws HCatException

Description copied from class: HCatClient

Serializer for HCatPartition.

Specified by:

serializePartition in class HCatClient

Parameters:

hcatPartition - The HCatPartition instance to be serialized.

Returns:

String representation of the HCatPartition.

Throws:

HCatException

serializePartitions

public List<String> serializePartitions(List<HCatPartition> hcatPartitions)
                                 throws HCatException

Description copied from class: HCatClient

Serializer for a list of HCatPartition.

Specified by:

serializePartitions in class HCatClient

Parameters:

hcatPartitions - The HCatPartitions to be serialized.

Returns:

A list of Strings, each representing an HCatPartition.

Throws:

HCatException

deserializePartition

public HCatPartition deserializePartition(String hcatPartitionStringRep)
                                   throws HCatException

Description copied from class: HCatClient

Deserializer for an HCatPartition.

Specified by:

deserializePartition in class HCatClient

Parameters:

hcatPartitionStringRep - The String representation of the HCatPartition, presumably retrieved from HCatClient.serializePartition(HCatPartition)

Returns:

HCatPartition instance reconstructed from the string.

Throws:

HCatException

deserializePartitions

public List<HCatPartition> deserializePartitions(List<String> hcatPartitionStringReps)
                                          throws HCatException

Description copied from class: HCatClient

Deserializer for a list of HCatPartition strings.

Specified by:

deserializePartitions in class HCatClient

Parameters:

hcatPartitionStringReps - The list of HCatPartition strings to be deserialized.

Returns:

A list of HCatPartition instances, each reconstructed from an entry in the string-list.

Throws:

HCatException

serializePartitionSpec

public List<String> serializePartitionSpec(HCatPartitionSpec partitionSpec)
                                    throws HCatException

Description copied from class: HCatClient

Serializer for HCatPartitionSpec.

Specified by:

serializePartitionSpec in class HCatClient

Parameters:

partitionSpec - HCatPartitionSpec to be serialized.

Returns:

A list of Strings, representing the HCatPartitionSpec as a whole.

Throws:

HCatException - On failure to serialize.

deserializePartitionSpec

public HCatPartitionSpec deserializePartitionSpec(List<String> hcatPartitionSpecStrings)
                                           throws HCatException

Description copied from class: HCatClient

Deserializer for HCatPartitionSpec.

Specified by:

deserializePartitionSpec in class HCatClient

Parameters:

hcatPartitionSpecStrings - List of strings, representing the HCatPartitionSpec as a whole.

Returns:

HCatPartitionSpec, reconstructed from the list of strings.

Throws:

HCatException - On failure to deserialize.