alluxio.cli.hms

Class CreateHmsClientValidationTask

java.lang.Object

alluxio.cli.AbstractValidationTask

alluxio.cli.hms.MetastoreValidationTask<String,org.apache.hadoop.hive.metastore.IMetaStoreClient>

alluxio.cli.hms.CreateHmsClientValidationTask

All Implemented Interfaces:

ValidationTask

public class CreateHmsClientValidationTask
extends MetastoreValidationTask<String,org.apache.hadoop.hive.metastore.IMetaStoreClient>

A validation task that generates a new Hive Metastore client and verifies the connection.

Field Summary

Fields inherited from class alluxio.cli.hms.MetastoreValidationTask

mInputTask

Constructor Summary

Constructors

Constructor and Description
CreateHmsClientValidationTask(int socketTimeout, MetastoreValidationTask<?,String> input) Create a new instance of CreateHmsClientValidationTask.

Method Summary

Modifier and Type	Method and Description
String	getName() Gets the name of the task.
protected Pair<ValidationTaskResult,org.apache.hadoop.hive.metastore.IMetaStoreClient>	getValidationWithResult()
ValidationTaskResult	validateImpl(Map<String,String> optionMap)

Methods inherited from class alluxio.cli.AbstractValidationTask

getOptionList, validate

Methods inherited from class java.lang.Object

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

Constructor Detail

CreateHmsClientValidationTask

public CreateHmsClientValidationTask(int socketTimeout,
                                     MetastoreValidationTask<?,String> input)

Create a new instance of CreateHmsClientValidationTask.

Parameters:

socketTimeout - the timeout when connecting to the metastore

input - the input task providing the URI(s)

Method Detail

getName

public String getName()

Description copied from interface: ValidationTask

Gets the name of the task.

Returns:

the task name

validateImpl

public ValidationTaskResult validateImpl(Map<String,String> optionMap)
                                  throws InterruptedException

Overrides:

validateImpl in class MetastoreValidationTask<String,org.apache.hadoop.hive.metastore.IMetaStoreClient>

Throws:

InterruptedException

getValidationWithResult

protected Pair<ValidationTaskResult,org.apache.hadoop.hive.metastore.IMetaStoreClient> getValidationWithResult()
                                                                                                        throws InterruptedException

Returns:

the result of the validation. Pair.getFirst() will be null if the connection to the metastore was successful, otherwise if there is a failure Pair.getSecond() will be null

Throws:

InterruptedException - if the task is interrupted