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, ARCHIVES, FILES

Constructor Summary

Constructors

Constructor and Description
HcatDelegator(AppConfig appConf, ExecService execService)

Method Summary

Methods

Modifier and Type	Method and Description
javax.ws.rs.core.Response	addOneColumn(String user, String db, String table, ColumnDesc desc) Add one column.
javax.ws.rs.core.Response	addOnePartition(String user, String db, String table, PartitionDesc desc) Add one partition.
javax.ws.rs.core.Response	addOneTableProperty(String user, String db, String table, TablePropertyDesc desc) Add one table property.
javax.ws.rs.core.Response	createDatabase(String user, DatabaseDesc desc) Create a database with the given name
javax.ws.rs.core.Response	createTable(String user, String db, TableDesc desc) Create a table.
javax.ws.rs.core.Response	createTableLike(String user, String db, TableLikeDesc desc) Create a table like another.
javax.ws.rs.core.Response	descDatabase(String user, String db, boolean extended) Return a json description of the database.
javax.ws.rs.core.Response	descExtendedTable(String user, String db, String table) Return a json "show table extended like" with extra info from "desc exteded" This will return table with exact name match.
javax.ws.rs.core.Response	descOneColumn(String user, String db, String table, String column) Return a json description of one column.
javax.ws.rs.core.Response	descOnePartition(String user, String db, String table, String partition) Return a json description of one partition.
javax.ws.rs.core.Response	descTable(String user, String db, String table, boolean extended) Return a json description of the table.
javax.ws.rs.core.Response	descTableProperty(String user, String db, String table, String property) Describe one table property.
javax.ws.rs.core.Response	dropDatabase(String user, String db, boolean ifExists, String option, String group, String permissions) Drop the given database
javax.ws.rs.core.Response	dropPartition(String user, String db, String table, String partition, boolean ifExists, String group, String permissions) Drop a partition.
javax.ws.rs.core.Response	dropTable(String user, String db, String table, boolean ifExists, String group, String permissions) Drop a table.
javax.ws.rs.core.Response	listColumns(String user, String db, String table) Return a json description of the columns.
javax.ws.rs.core.Response	listDatabases(String user, String dbPattern) Return a json "show databases like".
javax.ws.rs.core.Response	listPartitions(String user, String db, String table) Return a json description of the partitions.
javax.ws.rs.core.Response	listTableProperties(String user, String db, String table) List the table properties.
javax.ws.rs.core.Response	listTables(String user, String db, String tablePattern) Return a json "show table like".
javax.ws.rs.core.Response	renameTable(String user, String db, String oldTable, String newTable, String group, String permissions) Rename a table.
ExecBean	run(String user, String exec, boolean format, String group, 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(String user,
           String exec,
           boolean format,
           String group,
           String permissions)
             throws NotAuthorizedException,
                    BusyException,
                    org.apache.commons.exec.ExecuteException,
                    IOException

Run the local hcat executable.

Throws:

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

descDatabase

public javax.ws.rs.core.Response descDatabase(String user,
                                     String db,
                                     boolean extended)
                                       throws HcatException,
                                              NotAuthorizedException,
                                              BusyException,
                                              org.apache.commons.exec.ExecuteException,
                                              IOException

Return a json description of the database.

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

listDatabases

public javax.ws.rs.core.Response listDatabases(String user,
                                      String dbPattern)
                                        throws HcatException,
                                               NotAuthorizedException,
                                               BusyException,
                                               org.apache.commons.exec.ExecuteException,
                                               IOException

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

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

createDatabase

public javax.ws.rs.core.Response createDatabase(String user,
                                       DatabaseDesc desc)
                                         throws HcatException,
                                                NotAuthorizedException,
                                                BusyException,
                                                org.apache.commons.exec.ExecuteException,
                                                IOException

Create a database with the given name

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

dropDatabase

public javax.ws.rs.core.Response dropDatabase(String user,
                                     String db,
                                     boolean ifExists,
                                     String option,
                                     String group,
                                     String permissions)
                                       throws HcatException,
                                              NotAuthorizedException,
                                              BusyException,
                                              org.apache.commons.exec.ExecuteException,
                                              IOException

Drop the given database

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

createTable

public javax.ws.rs.core.Response createTable(String user,
                                    String db,
                                    TableDesc desc)
                                      throws HcatException,
                                             NotAuthorizedException,
                                             BusyException,
                                             org.apache.commons.exec.ExecuteException,
                                             IOException

Create a table.

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

createTableLike

public javax.ws.rs.core.Response createTableLike(String user,
                                        String db,
                                        TableLikeDesc desc)
                                          throws HcatException,
                                                 NotAuthorizedException,
                                                 BusyException,
                                                 org.apache.commons.exec.ExecuteException,
                                                 IOException

Create a table like another.

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

descTable

public javax.ws.rs.core.Response descTable(String user,
                                  String db,
                                  String table,
                                  boolean extended)
                                    throws HcatException,
                                           NotAuthorizedException,
                                           BusyException,
                                           org.apache.commons.exec.ExecuteException,
                                           IOException

Return a json description of the table.

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

listTables

public javax.ws.rs.core.Response listTables(String user,
                                   String db,
                                   String tablePattern)
                                     throws HcatException,
                                            NotAuthorizedException,
                                            BusyException,
                                            org.apache.commons.exec.ExecuteException,
                                            IOException

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

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

descExtendedTable

public javax.ws.rs.core.Response descExtendedTable(String user,
                                          String db,
                                          String table)
                                            throws HcatException,
                                                   NotAuthorizedException,
                                                   BusyException,
                                                   org.apache.commons.exec.ExecuteException,
                                                   IOException

Return a json "show table extended like" with extra info from "desc exteded" This will return table with exact name match.

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

dropTable

public javax.ws.rs.core.Response dropTable(String user,
                                  String db,
                                  String table,
                                  boolean ifExists,
                                  String group,
                                  String permissions)
                                    throws HcatException,
                                           NotAuthorizedException,
                                           BusyException,
                                           org.apache.commons.exec.ExecuteException,
                                           IOException

Drop a table.

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

renameTable

public javax.ws.rs.core.Response renameTable(String user,
                                    String db,
                                    String oldTable,
                                    String newTable,
                                    String group,
                                    String permissions)
                                      throws HcatException,
                                             NotAuthorizedException,
                                             BusyException,
                                             org.apache.commons.exec.ExecuteException,
                                             IOException

Rename a table.

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

descTableProperty

public javax.ws.rs.core.Response descTableProperty(String user,
                                          String db,
                                          String table,
                                          String property)
                                            throws HcatException,
                                                   NotAuthorizedException,
                                                   BusyException,
                                                   org.apache.commons.exec.ExecuteException,
                                                   IOException

Describe one table property.

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

listTableProperties

public javax.ws.rs.core.Response listTableProperties(String user,
                                            String db,
                                            String table)
                                              throws HcatException,
                                                     NotAuthorizedException,
                                                     BusyException,
                                                     org.apache.commons.exec.ExecuteException,
                                                     IOException

List the table properties.

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

addOneTableProperty

public javax.ws.rs.core.Response addOneTableProperty(String user,
                                            String db,
                                            String table,
                                            TablePropertyDesc desc)
                                              throws HcatException,
                                                     NotAuthorizedException,
                                                     BusyException,
                                                     org.apache.commons.exec.ExecuteException,
                                                     IOException

Add one table property.

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

listPartitions

public javax.ws.rs.core.Response listPartitions(String user,
                                       String db,
                                       String table)
                                         throws HcatException,
                                                NotAuthorizedException,
                                                BusyException,
                                                org.apache.commons.exec.ExecuteException,
                                                IOException

Return a json description of the partitions.

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

descOnePartition

public javax.ws.rs.core.Response descOnePartition(String user,
                                         String db,
                                         String table,
                                         String partition)
                                           throws HcatException,
                                                  NotAuthorizedException,
                                                  BusyException,
                                                  org.apache.commons.exec.ExecuteException,
                                                  IOException

Return a json description of one partition.

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

addOnePartition

public javax.ws.rs.core.Response addOnePartition(String user,
                                        String db,
                                        String table,
                                        PartitionDesc desc)
                                          throws HcatException,
                                                 NotAuthorizedException,
                                                 BusyException,
                                                 org.apache.commons.exec.ExecuteException,
                                                 IOException

Add one partition.

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

dropPartition

public javax.ws.rs.core.Response dropPartition(String user,
                                      String db,
                                      String table,
                                      String partition,
                                      boolean ifExists,
                                      String group,
                                      String permissions)
                                        throws HcatException,
                                               NotAuthorizedException,
                                               BusyException,
                                               org.apache.commons.exec.ExecuteException,
                                               IOException

Drop a partition.

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

listColumns

public javax.ws.rs.core.Response listColumns(String user,
                                    String db,
                                    String table)
                                      throws HcatException,
                                             NotAuthorizedException,
                                             BusyException,
                                             org.apache.commons.exec.ExecuteException,
                                             IOException

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

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

descOneColumn

public javax.ws.rs.core.Response descOneColumn(String user,
                                      String db,
                                      String table,
                                      String column)
                                        throws SimpleWebException,
                                               NotAuthorizedException,
                                               BusyException,
                                               org.apache.commons.exec.ExecuteException,
                                               IOException

Return a json description of one column.

Throws:

SimpleWebException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException

addOneColumn

public javax.ws.rs.core.Response addOneColumn(String user,
                                     String db,
                                     String table,
                                     ColumnDesc desc)
                                       throws HcatException,
                                              NotAuthorizedException,
                                              BusyException,
                                              org.apache.commons.exec.ExecuteException,
                                              IOException

Add one column.

Throws:

HcatException

NotAuthorizedException

BusyException

org.apache.commons.exec.ExecuteException

IOException