public class HcatDelegator extends LauncherDelegator
LauncherDelegator.JobType
runAs
appConf, 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, runTempletonControllerJob
public 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
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
public javax.ws.rs.core.Response descDatabase(String user, String db, boolean extended) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
public javax.ws.rs.core.Response listDatabases(String user, String dbPattern) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
public javax.ws.rs.core.Response createDatabase(String user, DatabaseDesc desc) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
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
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
public javax.ws.rs.core.Response createTable(String user, String db, TableDesc desc) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
public javax.ws.rs.core.Response createTableLike(String user, String db, TableLikeDesc desc) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
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
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
public javax.ws.rs.core.Response listTables(String user, String db, String tablePattern) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
public javax.ws.rs.core.Response descExtendedTable(String user, String db, String table) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
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
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
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
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
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
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
public javax.ws.rs.core.Response listTableProperties(String user, String db, String table) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
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
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
public javax.ws.rs.core.Response listPartitions(String user, String db, String table) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
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
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
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
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
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
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
public javax.ws.rs.core.Response listColumns(String user, String db, String table) throws HcatException, NotAuthorizedException, BusyException, org.apache.commons.exec.ExecuteException, IOException
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
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
SimpleWebException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
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
HcatException
NotAuthorizedException
BusyException
org.apache.commons.exec.ExecuteException
IOException
Copyright © 2019 The Apache Software Foundation. All rights reserved.