public class Server
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.util.regex.Pattern |
DDL_ID |
static java.lang.String |
DO_AS_PARAM |
protected static ExecService |
execService |
static java.util.Map<java.lang.String,java.lang.String> |
STATUS_OK
The status message.
|
static java.util.Map<java.lang.String,java.lang.Object> |
SUPPORTED_FORMATS
The list of supported return formats.
|
static java.util.Map<java.lang.String,java.lang.Object> |
SUPPORTED_VERSIONS
The list of supported api versions.
|
static java.lang.String |
VERSION |
Constructor and Description |
---|
Server() |
Modifier and Type | Method and Description |
---|---|
Response |
addOneColumn(java.lang.String db,
java.lang.String table,
java.lang.String column,
ColumnDesc desc)
Create a column in an hcat table.
|
Response |
addOnePartition(java.lang.String db,
java.lang.String table,
java.lang.String partition,
PartitionDesc desc)
Create a partition in an hcat table.
|
Response |
addOneTableProperty(java.lang.String db,
java.lang.String table,
java.lang.String property,
TablePropertyDesc desc)
Add a single property on an hcat table.
|
CompleteBean |
completeJob(java.lang.String jobid)
Notify on a completed job.
|
Response |
createDatabase(java.lang.String db,
DatabaseDesc desc)
Create a database
|
Response |
createTable(java.lang.String db,
java.lang.String table,
TableDesc desc)
Create a new table.
|
Response |
createTableLike(java.lang.String db,
java.lang.String existingTable,
java.lang.String newTable,
TableLikeDesc desc)
Create a new table like another table.
|
ExecBean |
ddl(java.lang.String exec,
java.lang.String group,
java.lang.String permissions)
Execute an hcat ddl expression on the local box.
|
QueueStatusBean |
deleteJobId(java.lang.String jobid)
Kill a job in the queue.
|
QueueStatusBean |
deleteQueueId(java.lang.String jobid)
Deprecated.
use DELETE jobs/{jobid} instead.
|
Response |
descColumn(java.lang.String db,
java.lang.String table,
java.lang.String column)
Describe a single column in an hcat table.
|
Response |
descDatabase(java.lang.String db,
java.lang.String format)
Describe a database
|
Response |
descOneTableProperty(java.lang.String db,
java.lang.String table,
java.lang.String property)
Describe a single property on an hcat table.
|
Response |
descPartition(java.lang.String db,
java.lang.String table,
java.lang.String partition)
Describe a single partition in an hcat table.
|
Response |
descTable(java.lang.String db,
java.lang.String table,
java.lang.String format)
Describe an hcat table.
|
Response |
dropDatabase(java.lang.String db,
boolean ifExists,
java.lang.String option,
java.lang.String group,
java.lang.String permissions)
Drop a database
|
Response |
dropPartition(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 in an hcat table.
|
Response |
dropTable(java.lang.String db,
java.lang.String table,
boolean ifExists,
java.lang.String group,
java.lang.String permissions)
Drop an hcat table.
|
java.lang.String |
getCompletedUrl()
The callback url on this server when a task is completed.
|
EnqueueBean |
hive(java.lang.String execute,
java.lang.String srcFile,
java.util.List<java.lang.String> hiveArgs,
java.lang.String otherFiles,
java.util.List<java.lang.String> defines,
java.lang.String statusdir,
java.lang.String callback,
boolean enablelog)
Run a Hive job.
|
Response |
listColumns(java.lang.String db,
java.lang.String table)
List the columns in an hcat table.
|
Response |
listDatabases(java.lang.String dbPattern)
List all databases, or those that match a pattern.
|
Response |
listPartitions(java.lang.String db,
java.lang.String table)
List all the partitions in an hcat table.
|
Response |
listTableProperties(java.lang.String db,
java.lang.String table)
List all the properties on an hcat table.
|
Response |
listTables(java.lang.String db,
java.lang.String tablePattern)
List all the tables in an hcat database.
|
EnqueueBean |
mapReduceJar(java.lang.String jar,
java.lang.String mainClass,
java.lang.String libjars,
java.lang.String files,
java.util.List<java.lang.String> args,
java.util.List<java.lang.String> defines,
java.lang.String statusdir,
java.lang.String callback,
boolean enablelog)
Run a MapReduce Jar job.
|
EnqueueBean |
mapReduceStreaming(java.util.List<java.lang.String> inputs,
java.lang.String output,
java.lang.String mapper,
java.lang.String reducer,
java.lang.String combiner,
java.util.List<java.lang.String> fileList,
java.lang.String files,
java.util.List<java.lang.String> defines,
java.util.List<java.lang.String> cmdenvs,
java.util.List<java.lang.String> args,
java.lang.String statusdir,
java.lang.String callback,
boolean enablelog)
Run a MapReduce Streaming job.
|
EnqueueBean |
pig(java.lang.String execute,
java.lang.String srcFile,
java.util.List<java.lang.String> pigArgs,
java.lang.String otherFiles,
java.lang.String statusdir,
java.lang.String callback,
boolean enablelog)
Run a Pig job.
|
Response |
renameTable(java.lang.String db,
java.lang.String oldTable,
java.lang.String newTable,
java.lang.String group,
java.lang.String permissions)
Rename an hcat table.
|
java.util.Map<java.lang.String,java.lang.Object> |
requestFormats()
Check the supported request formats of this server.
|
QueueStatusBean |
showJobId(java.lang.String jobid)
Return the status of the jobid.
|
java.util.List<JobItemBean> |
showJobList(java.lang.String fields,
boolean showall)
Return all the known job ids for this user.
|
QueueStatusBean |
showQueueId(java.lang.String jobid)
Deprecated.
use GET jobs/{jobid} instead.
|
java.util.List<java.lang.String> |
showQueueList(boolean showall)
Deprecated.
use GET jobs instead.
|
java.util.Map<java.lang.String,java.lang.String> |
status()
Check the status of this server.
|
void |
verifyDdlParam(java.lang.String param,
java.lang.String name)
Verify that the parameter exists and is a simple DDL identifier
name.
|
void |
verifyParam(java.util.List<java.lang.String> param,
java.lang.String name)
Verify that the parameter exists.
|
void |
verifyParam(java.lang.String param,
java.lang.String name)
Verify that the parameter exists.
|
void |
verifyUser()
Verify that we have a valid user.
|
java.util.Map<java.lang.String,java.lang.Object> |
version()
Check the version(s) supported by this server.
|
public static final java.lang.String VERSION
public static final java.lang.String DO_AS_PARAM
public static final java.util.Map<java.lang.String,java.lang.String> STATUS_OK
public static final java.util.Map<java.lang.String,java.lang.Object> SUPPORTED_VERSIONS
public static final java.util.Map<java.lang.String,java.lang.Object> SUPPORTED_FORMATS
protected static ExecService execService
public static final java.util.regex.Pattern DDL_ID
public java.util.Map<java.lang.String,java.lang.String> status()
public java.util.Map<java.lang.String,java.lang.Object> requestFormats()
public java.util.Map<java.lang.String,java.lang.Object> version()
public ExecBean ddl(java.lang.String exec, java.lang.String group, java.lang.String permissions) throws NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response listTables(java.lang.String db, java.lang.String tablePattern) throws HcatException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response createTable(java.lang.String db, java.lang.String table, TableDesc desc) throws SimpleWebException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
SimpleWebException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response createTableLike(java.lang.String db, java.lang.String existingTable, java.lang.String newTable, TableLikeDesc desc) throws SimpleWebException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
SimpleWebException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response descTable(java.lang.String db, java.lang.String table, java.lang.String format) throws HcatException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response dropTable(java.lang.String db, java.lang.String table, boolean ifExists, java.lang.String group, java.lang.String permissions) throws HcatException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response renameTable(java.lang.String db, java.lang.String oldTable, java.lang.String newTable, java.lang.String group, java.lang.String permissions) throws HcatException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response descOneTableProperty(java.lang.String db, java.lang.String table, java.lang.String property) throws HcatException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response listTableProperties(java.lang.String db, java.lang.String table) throws HcatException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response addOneTableProperty(java.lang.String db, java.lang.String table, java.lang.String property, TablePropertyDesc desc) throws HcatException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response listPartitions(java.lang.String db, java.lang.String table) throws HcatException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response descPartition(java.lang.String db, java.lang.String table, java.lang.String partition) throws HcatException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response addOnePartition(java.lang.String db, java.lang.String table, java.lang.String partition, PartitionDesc desc) throws HcatException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response dropPartition(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, BadParam, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response listDatabases(java.lang.String dbPattern) throws HcatException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response descDatabase(java.lang.String db, java.lang.String format) throws HcatException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response createDatabase(java.lang.String db, DatabaseDesc desc) throws HcatException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response dropDatabase(java.lang.String db, boolean ifExists, java.lang.String option, java.lang.String group, java.lang.String permissions) throws HcatException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response listColumns(java.lang.String db, java.lang.String table) throws HcatException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response descColumn(java.lang.String db, java.lang.String table, java.lang.String column) throws SimpleWebException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
SimpleWebException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public Response addOneColumn(java.lang.String db, java.lang.String table, java.lang.String column, ColumnDesc desc) throws HcatException, NotAuthorizedException, BusyException, BadParam, ExecuteException, java.io.IOException
HcatException
NotAuthorizedException
BusyException
BadParam
ExecuteException
java.io.IOException
public EnqueueBean mapReduceStreaming(java.util.List<java.lang.String> inputs, java.lang.String output, java.lang.String mapper, java.lang.String reducer, java.lang.String combiner, java.util.List<java.lang.String> fileList, java.lang.String files, java.util.List<java.lang.String> defines, java.util.List<java.lang.String> cmdenvs, java.util.List<java.lang.String> args, java.lang.String statusdir, java.lang.String callback, boolean enablelog) throws NotAuthorizedException, BusyException, BadParam, QueueException, ExecuteException, java.io.IOException, java.lang.InterruptedException
NotAuthorizedException
BusyException
BadParam
QueueException
ExecuteException
java.io.IOException
java.lang.InterruptedException
public EnqueueBean mapReduceJar(java.lang.String jar, java.lang.String mainClass, java.lang.String libjars, java.lang.String files, java.util.List<java.lang.String> args, java.util.List<java.lang.String> defines, java.lang.String statusdir, java.lang.String callback, boolean enablelog) throws NotAuthorizedException, BusyException, BadParam, QueueException, ExecuteException, java.io.IOException, java.lang.InterruptedException
NotAuthorizedException
BusyException
BadParam
QueueException
ExecuteException
java.io.IOException
java.lang.InterruptedException
public EnqueueBean pig(java.lang.String execute, java.lang.String srcFile, java.util.List<java.lang.String> pigArgs, java.lang.String otherFiles, java.lang.String statusdir, java.lang.String callback, boolean enablelog) throws NotAuthorizedException, BusyException, BadParam, QueueException, ExecuteException, java.io.IOException, java.lang.InterruptedException
NotAuthorizedException
BusyException
BadParam
QueueException
ExecuteException
java.io.IOException
java.lang.InterruptedException
public EnqueueBean hive(java.lang.String execute, java.lang.String srcFile, java.util.List<java.lang.String> hiveArgs, java.lang.String otherFiles, java.util.List<java.lang.String> defines, java.lang.String statusdir, java.lang.String callback, boolean enablelog) throws NotAuthorizedException, BusyException, BadParam, QueueException, ExecuteException, java.io.IOException, java.lang.InterruptedException
execute
- SQL statement to run, equivalent to "-e" from hive command linesrcFile
- name of hive script file to run, equivalent to "-f" from hive
command linehiveArgs
- additional command line argument passed to the hive command line.
Please check https://cwiki.apache.org/Hive/languagemanual-cli.html
for detailed explanation of command line argumentsotherFiles
- additional files to be shipped to the launcher, such as the jars
used in "add jar" statement in hive scriptdefines
- shortcut for command line arguments "--define"statusdir
- where the stderr/stdout of templeton controller job goescallback
- callback url when the hive job finishesenablelog
- whether to collect mapreduce log into statusdir/logsNotAuthorizedException
BusyException
BadParam
QueueException
ExecuteException
java.io.IOException
java.lang.InterruptedException
@Deprecated public QueueStatusBean showQueueId(java.lang.String jobid) throws NotAuthorizedException, BadParam, java.io.IOException, java.lang.InterruptedException
NotAuthorizedException
BadParam
java.io.IOException
java.lang.InterruptedException
@Deprecated public QueueStatusBean deleteQueueId(java.lang.String jobid) throws NotAuthorizedException, BadParam, java.io.IOException, java.lang.InterruptedException
NotAuthorizedException
BadParam
java.io.IOException
java.lang.InterruptedException
@Deprecated public java.util.List<java.lang.String> showQueueList(boolean showall) throws NotAuthorizedException, BadParam, java.io.IOException, java.lang.InterruptedException
NotAuthorizedException
BadParam
java.io.IOException
java.lang.InterruptedException
public QueueStatusBean showJobId(java.lang.String jobid) throws NotAuthorizedException, BadParam, java.io.IOException, java.lang.InterruptedException
NotAuthorizedException
BadParam
java.io.IOException
java.lang.InterruptedException
public QueueStatusBean deleteJobId(java.lang.String jobid) throws NotAuthorizedException, BadParam, java.io.IOException, java.lang.InterruptedException
NotAuthorizedException
BadParam
java.io.IOException
java.lang.InterruptedException
public java.util.List<JobItemBean> showJobList(java.lang.String fields, boolean showall) throws NotAuthorizedException, BadParam, java.io.IOException, java.lang.InterruptedException
NotAuthorizedException
BadParam
java.io.IOException
java.lang.InterruptedException
public CompleteBean completeJob(java.lang.String jobid) throws CallbackFailedException, java.io.IOException
CallbackFailedException
java.io.IOException
public void verifyUser() throws NotAuthorizedException
NotAuthorizedException
public void verifyParam(java.lang.String param, java.lang.String name) throws BadParam
BadParam
public void verifyParam(java.util.List<java.lang.String> param, java.lang.String name) throws BadParam
BadParam
public void verifyDdlParam(java.lang.String param, java.lang.String name) throws BadParam
BadParam
public java.lang.String getCompletedUrl()
Copyright © 2012 The Apache Software Foundation