alluxio.cli.hms

Class CreateHmsClientValidationTask

java.lang.Object

alluxio.cli.AbstractValidationTask

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

alluxio.cli.hms.CreateHmsClientValidationTask

All Implemented Interfaces:

ValidationTask

public class CreateHmsClientValidationTask
extends MetastoreValidationTask<java.lang.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<?,java.lang.String> input) Create a new instance of CreateHmsClientValidationTask.

Method Summary

Modifier and Type	Method and Description
java.lang.String	getName()
protected Pair<ValidationTaskResult,org.apache.hadoop.hive.metastore.IMetaStoreClient>	getValidationWithResult()
ValidationTaskResult	validateImpl(java.util.Map<java.lang.String,java.lang.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<?,java.lang.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 java.lang.String getName()

validateImpl

public ValidationTaskResult validateImpl(java.util.Map<java.lang.String,java.lang.String> optionMap)
                                  throws java.lang.InterruptedException

Overrides:

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

Throws:

java.lang.InterruptedException

getValidationWithResult

protected Pair<ValidationTaskResult,org.apache.hadoop.hive.metastore.IMetaStoreClient> getValidationWithResult()
                                                                                                        throws java.lang.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:

java.lang.InterruptedException - if the task is interrupted