org.apache.hive.beeline

Class HiveSchemaTool

java.lang.Object

org.apache.hive.beeline.HiveSchemaTool

public class HiveSchemaTool
extends Object

Constructor Summary

Constructors

Constructor and Description
HiveSchemaTool(String hiveHome, HiveConf hiveConf, String dbType, String metaDbType)
HiveSchemaTool(String dbType, String metaDbType)

Method Summary

Modifier and Type	Method and Description
void	doInit() Initialize the metastore schema to current version
void	doInit(String toVersion) Initialize the metastore schema
void	doUpgrade() Perform metastore schema upgrade.
void	doUpgrade(String fromSchemaVer) Perform metastore schema upgrade
void	doValidate()
HiveConf	getHiveConf()
static void	main(String[] args)
void	runBeeLine(String sqlScriptFile)
void	setDbOpts(String dbOpts)
void	setDriver(String driver)
void	setDryRun(boolean dryRun)
void	setPassWord(String passWord)
void	setUrl(String url)
void	setUserName(String userName)
void	setValidationServers(String servers)
void	setVerbose(boolean verbose)
void	showInfo() Print Hive version and schema version
void	verifySchemaVersion() check if the current schema version in metastore matches the Hive version

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveSchemaTool

public HiveSchemaTool(String dbType,
                      String metaDbType)
               throws HiveMetaException

Throws:

HiveMetaException

HiveSchemaTool

public HiveSchemaTool(String hiveHome,
                      HiveConf hiveConf,
                      String dbType,
                      String metaDbType)
               throws HiveMetaException

Throws:

HiveMetaException

Method Detail

getHiveConf

public HiveConf getHiveConf()

setUrl

public void setUrl(String url)

setDriver

public void setDriver(String driver)

setUserName

public void setUserName(String userName)

setPassWord

public void setPassWord(String passWord)

setDryRun

public void setDryRun(boolean dryRun)

setVerbose

public void setVerbose(boolean verbose)

setDbOpts

public void setDbOpts(String dbOpts)

setValidationServers

public void setValidationServers(String servers)

showInfo

public void showInfo()
              throws HiveMetaException

Print Hive version and schema version

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

HiveMetaException

verifySchemaVersion

public void verifySchemaVersion()
                         throws HiveMetaException

check if the current schema version in metastore matches the Hive version

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

HiveMetaException

doUpgrade

public void doUpgrade()
               throws HiveMetaException

Perform metastore schema upgrade. extract the current schema version from metastore

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

HiveMetaException

doUpgrade

public void doUpgrade(String fromSchemaVer)
               throws HiveMetaException

Perform metastore schema upgrade

Parameters:

fromSchemaVer - Existing version of the metastore. If null, then read from the metastore

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

HiveMetaException

doInit

public void doInit()
            throws HiveMetaException

Initialize the metastore schema to current version

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

HiveMetaException

doInit

public void doInit(String toVersion)
            throws HiveMetaException

Initialize the metastore schema

Parameters:

toVersion - If null then current hive version is used

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

HiveMetaException

doValidate

public void doValidate()
                throws HiveMetaException

Throws:

HiveMetaException

runBeeLine

public void runBeeLine(String sqlScriptFile)
                throws IOException

Throws:

IOException

main

public static void main(String[] args)