public class HcatDelegator extends LauncherDelegator
LauncherDelegator.JobType
runAs
appConf
Constructor and Description |
---|
HcatDelegator(AppConfig appConf,
ExecService execService) |
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.
|
addCacheFiles, addDef, enqueueController, makeLauncherArgs, makeOverrideClasspath, registerJob
public HcatDelegator(AppConfig appConf, ExecService execService)
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
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
public Response descDatabase(java.lang.String user, java.lang.String db, boolean extended) throws HcatException, NotAuthorizedException, BusyException, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
public Response listDatabases(java.lang.String user, java.lang.String dbPattern) throws HcatException, NotAuthorizedException, BusyException, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
public Response createDatabase(java.lang.String user, DatabaseDesc desc) throws HcatException, NotAuthorizedException, BusyException, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
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
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
public Response createTable(java.lang.String user, java.lang.String db, TableDesc desc) throws HcatException, NotAuthorizedException, BusyException, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
public Response createTableLike(java.lang.String user, java.lang.String db, TableLikeDesc desc) throws HcatException, NotAuthorizedException, BusyException, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
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
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
public Response listTables(java.lang.String user, java.lang.String db, java.lang.String tablePattern) throws HcatException, NotAuthorizedException, BusyException, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
public Response descExtendedTable(java.lang.String user, java.lang.String db, java.lang.String table) throws HcatException, NotAuthorizedException, BusyException, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
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
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
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
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
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
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
public Response listTableProperties(java.lang.String user, java.lang.String db, java.lang.String table) throws HcatException, NotAuthorizedException, BusyException, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
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
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
public Response listPartitions(java.lang.String user, java.lang.String db, java.lang.String table) throws HcatException, NotAuthorizedException, BusyException, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
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
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
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
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
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
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
public Response listColumns(java.lang.String user, java.lang.String db, java.lang.String table) throws HcatException, NotAuthorizedException, BusyException, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
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
SimpleWebException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
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
HcatException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
Copyright © 2012 The Apache Software Foundation