public class HcatDelegator extends LauncherDelegator
LauncherDelegator.JobTyperunAsappConf, ARCHIVES, FILES| Constructor and Description |
|---|
HcatDelegator(AppConfig appConf,
ExecService execService) |
| 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.
|
addCacheFiles, addDef, enqueueController, enqueueJob, getTempletonController, killJob, makeLauncherArgs, makeOverrideClasspath, registerJob, runTempletonControllerJobpublic HcatDelegator(AppConfig appConf, ExecService execService)
public ExecBean run(String user, String exec, boolean format, String group, String permissions) throws NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
NotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic javax.ws.rs.core.Response descDatabase(String user, String db, boolean extended) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic javax.ws.rs.core.Response listDatabases(String user, String dbPattern) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic javax.ws.rs.core.Response createDatabase(String user, DatabaseDesc desc) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic 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
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic javax.ws.rs.core.Response createTable(String user, String db, TableDesc desc) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic javax.ws.rs.core.Response createTableLike(String user, String db, TableLikeDesc desc) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic javax.ws.rs.core.Response descTable(String user, String db, String table, boolean extended) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic javax.ws.rs.core.Response listTables(String user, String db, String tablePattern) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic javax.ws.rs.core.Response descExtendedTable(String user, String db, String table) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic 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
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic 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
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic javax.ws.rs.core.Response descTableProperty(String user, String db, String table, String property) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic javax.ws.rs.core.Response listTableProperties(String user, String db, String table) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic javax.ws.rs.core.Response addOneTableProperty(String user, String db, String table, TablePropertyDesc desc) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic javax.ws.rs.core.Response listPartitions(String user, String db, String table) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic javax.ws.rs.core.Response descOnePartition(String user, String db, String table, String partition) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic javax.ws.rs.core.Response addOnePartition(String user, String db, String table, PartitionDesc desc) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic 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
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic javax.ws.rs.core.Response listColumns(String user, String db, String table) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic javax.ws.rs.core.Response descOneColumn(String user, String db, String table, String column) throws SimpleWebException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
SimpleWebExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionpublic javax.ws.rs.core.Response addOneColumn(String user, String db, String table, ColumnDesc desc) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatExceptionNotAuthorizedExceptionBusyExceptionorg.apache.commons.exec.ExecuteExceptionIOExceptionCopyright © 2019 The Apache Software Foundation. All Rights Reserved.