org.apache.hive.hcatalog.templeton

Class HcatDelegator

java.lang.Object

org.apache.hive.hcatalog.templeton.TempletonDelegator

org.apache.hive.hcatalog.templeton.LauncherDelegator

org.apache.hive.hcatalog.templeton.HcatDelegator

public class HcatDelegator
extends LauncherDelegator

Run hcat on the local server using the ExecService. This is the backend of the ddl web service.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hive.hcatalog.templeton.LauncherDelegator

LauncherDelegator.JobType

Field Summary

Fields inherited from class org.apache.hive.hcatalog.templeton.LauncherDelegator

runAs

Fields inherited from class org.apache.hive.hcatalog.templeton.TempletonDelegator

appConf

Constructor Summary

Constructors

Constructor and Description
HcatDelegator(AppConfig appConf, ExecService execService)

Method Summary

Modifier and Type	Method and Description
Response	addOneColumn(java.lang.String user, java.lang.String db, java.lang.String table, ColumnDesc desc) Add one column.
Response	addOnePartition(java.lang.String user, java.lang.String db, java.lang.String table, PartitionDesc desc) Add one partition.
Response	addOneTableProperty(java.lang.String user, java.lang.String db, java.lang.String table, TablePropertyDesc desc) Add one table property.
Response	createDatabase(java.lang.String user, DatabaseDesc desc) Create a database with the given name
Response	createTable(java.lang.String user, java.lang.String db, TableDesc desc) Create a table.
Response	createTableLike(java.lang.String user, java.lang.String db, TableLikeDesc desc) Create a table like another.
Response	descDatabase(java.lang.String user, java.lang.String db, boolean extended) Return a json description of the database.
Response	descExtendedTable(java.lang.String user, java.lang.String db, java.lang.String table) Return a json "show table extended like".
Response	descOneColumn(java.lang.String user, java.lang.String db, java.lang.String table, java.lang.String column) Return a json description of one column.
Response	descOnePartition(java.lang.String user, java.lang.String db, java.lang.String table, java.lang.String partition) Return a json description of one partition.
Response	descTable(java.lang.String user, java.lang.String db, java.lang.String table, boolean extended) Return a json description of the table.
Response	descTableProperty(java.lang.String user, java.lang.String db, java.lang.String table, java.lang.String property) Describe one table property.
Response	dropDatabase(java.lang.String user, java.lang.String db, boolean ifExists, java.lang.String option, java.lang.String group, java.lang.String permissions) Drop the given database
Response	dropPartition(java.lang.String user, java.lang.String db, java.lang.String table, java.lang.String partition, boolean ifExists, java.lang.String group, java.lang.String permissions) Drop a partition.
Response	dropTable(java.lang.String user, java.lang.String db, java.lang.String table, boolean ifExists, java.lang.String group, java.lang.String permissions) Drop a table.
Response	listColumns(java.lang.String user, java.lang.String db, java.lang.String table) Return a json description of the columns.
Response	listDatabases(java.lang.String user, java.lang.String dbPattern) Return a json "show databases like".
Response	listPartitions(java.lang.String user, java.lang.String db, java.lang.String table) Return a json description of the partitions.
Response	listTableProperties(java.lang.String user, java.lang.String db, java.lang.String table) List the table properties.
Response	listTables(java.lang.String user, java.lang.String db, java.lang.String tablePattern) Return a json "show table like".
Response	renameTable(java.lang.String user, java.lang.String db, java.lang.String oldTable, java.lang.String newTable, java.lang.String group, java.lang.String permissions) Rename a table.
ExecBean	run(java.lang.String user, java.lang.String exec, boolean format, java.lang.String group, java.lang.String permissions) Run the local hcat executable.

Methods inherited from class org.apache.hive.hcatalog.templeton.LauncherDelegator

addCacheFiles, addDef, enqueueController, makeLauncherArgs, makeOverrideClasspath, registerJob

Methods inherited from class java.lang.Object

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

Constructor Detail

HcatDelegator

public HcatDelegator(AppConfig appConf,
                     ExecService execService)

Method Detail

run

public ExecBean run(java.lang.String user,
                    java.lang.String exec,
                    boolean format,
                    java.lang.String group,
                    java.lang.String permissions)
             throws NotAuthorizedException,
                    BusyException,
                    ExecuteException,
                    java.io.IOException

Run the local hcat executable.

Throws:

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

descDatabase

public Response descDatabase(java.lang.String user,
                             java.lang.String db,
                             boolean extended)
                      throws HcatException,
                             NotAuthorizedException,
                             BusyException,
                             ExecuteException,
                             java.io.IOException

Return a json description of the database.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

listDatabases

public Response listDatabases(java.lang.String user,
                              java.lang.String dbPattern)
                       throws HcatException,
                              NotAuthorizedException,
                              BusyException,
                              ExecuteException,
                              java.io.IOException

Return a json "show databases like". This will return a list of databases.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

createDatabase

public Response createDatabase(java.lang.String user,
                               DatabaseDesc desc)
                        throws HcatException,
                               NotAuthorizedException,
                               BusyException,
                               ExecuteException,
                               java.io.IOException

Create a database with the given name

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

dropDatabase

public Response dropDatabase(java.lang.String user,
                             java.lang.String db,
                             boolean ifExists,
                             java.lang.String option,
                             java.lang.String group,
                             java.lang.String permissions)
                      throws HcatException,
                             NotAuthorizedException,
                             BusyException,
                             ExecuteException,
                             java.io.IOException

Drop the given database

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

createTable

public Response createTable(java.lang.String user,
                            java.lang.String db,
                            TableDesc desc)
                     throws HcatException,
                            NotAuthorizedException,
                            BusyException,
                            ExecuteException,
                            java.io.IOException

Create a table.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

createTableLike

public Response createTableLike(java.lang.String user,
                                java.lang.String db,
                                TableLikeDesc desc)
                         throws HcatException,
                                NotAuthorizedException,
                                BusyException,
                                ExecuteException,
                                java.io.IOException

Create a table like another.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

descTable

public Response descTable(java.lang.String user,
                          java.lang.String db,
                          java.lang.String table,
                          boolean extended)
                   throws HcatException,
                          NotAuthorizedException,
                          BusyException,
                          ExecuteException,
                          java.io.IOException

Return a json description of the table.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

listTables

public Response listTables(java.lang.String user,
                           java.lang.String db,
                           java.lang.String tablePattern)
                    throws HcatException,
                           NotAuthorizedException,
                           BusyException,
                           ExecuteException,
                           java.io.IOException

Return a json "show table like". This will return a list of tables.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

descExtendedTable

public Response descExtendedTable(java.lang.String user,
                                  java.lang.String db,
                                  java.lang.String table)
                           throws HcatException,
                                  NotAuthorizedException,
                                  BusyException,
                                  ExecuteException,
                                  java.io.IOException

Return a json "show table extended like". This will return only the first single table.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

dropTable

public Response dropTable(java.lang.String user,
                          java.lang.String db,
                          java.lang.String table,
                          boolean ifExists,
                          java.lang.String group,
                          java.lang.String permissions)
                   throws HcatException,
                          NotAuthorizedException,
                          BusyException,
                          ExecuteException,
                          java.io.IOException

Drop a table.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

renameTable

public Response renameTable(java.lang.String user,
                            java.lang.String db,
                            java.lang.String oldTable,
                            java.lang.String newTable,
                            java.lang.String group,
                            java.lang.String permissions)
                     throws HcatException,
                            NotAuthorizedException,
                            BusyException,
                            ExecuteException,
                            java.io.IOException

Rename a table.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

descTableProperty

public Response descTableProperty(java.lang.String user,
                                  java.lang.String db,
                                  java.lang.String table,
                                  java.lang.String property)
                           throws HcatException,
                                  NotAuthorizedException,
                                  BusyException,
                                  ExecuteException,
                                  java.io.IOException

Describe one table property.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

listTableProperties

public Response listTableProperties(java.lang.String user,
                                    java.lang.String db,
                                    java.lang.String table)
                             throws HcatException,
                                    NotAuthorizedException,
                                    BusyException,
                                    ExecuteException,
                                    java.io.IOException

List the table properties.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

addOneTableProperty

public Response addOneTableProperty(java.lang.String user,
                                    java.lang.String db,
                                    java.lang.String table,
                                    TablePropertyDesc desc)
                             throws HcatException,
                                    NotAuthorizedException,
                                    BusyException,
                                    ExecuteException,
                                    java.io.IOException

Add one table property.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

listPartitions

public Response listPartitions(java.lang.String user,
                               java.lang.String db,
                               java.lang.String table)
                        throws HcatException,
                               NotAuthorizedException,
                               BusyException,
                               ExecuteException,
                               java.io.IOException

Return a json description of the partitions.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

descOnePartition

public Response descOnePartition(java.lang.String user,
                                 java.lang.String db,
                                 java.lang.String table,
                                 java.lang.String partition)
                          throws HcatException,
                                 NotAuthorizedException,
                                 BusyException,
                                 ExecuteException,
                                 java.io.IOException

Return a json description of one partition.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

addOnePartition

public Response addOnePartition(java.lang.String user,
                                java.lang.String db,
                                java.lang.String table,
                                PartitionDesc desc)
                         throws HcatException,
                                NotAuthorizedException,
                                BusyException,
                                ExecuteException,
                                java.io.IOException

Add one partition.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

dropPartition

public Response dropPartition(java.lang.String user,
                              java.lang.String db,
                              java.lang.String table,
                              java.lang.String partition,
                              boolean ifExists,
                              java.lang.String group,
                              java.lang.String permissions)
                       throws HcatException,
                              NotAuthorizedException,
                              BusyException,
                              ExecuteException,
                              java.io.IOException

Drop a partition.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

listColumns

public Response listColumns(java.lang.String user,
                            java.lang.String db,
                            java.lang.String table)
                     throws HcatException,
                            NotAuthorizedException,
                            BusyException,
                            ExecuteException,
                            java.io.IOException

Return a json description of the columns. Same as describeTable.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

descOneColumn

public Response descOneColumn(java.lang.String user,
                              java.lang.String db,
                              java.lang.String table,
                              java.lang.String column)
                       throws SimpleWebException,
                              NotAuthorizedException,
                              BusyException,
                              ExecuteException,
                              java.io.IOException

Return a json description of one column.

Throws:

SimpleWebException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException

addOneColumn

public Response addOneColumn(java.lang.String user,
                             java.lang.String db,
                             java.lang.String table,
                             ColumnDesc desc)
                      throws HcatException,
                             NotAuthorizedException,
                             BusyException,
                             ExecuteException,
                             java.io.IOException

Add one column.

Throws:

HcatException

NotAuthorizedException

BusyException

ExecuteException

java.io.IOException