| Package | Description |
|---|---|
| org.apache.hive.hcatalog.templeton |
| Modifier and Type | Method and Description |
|---|---|
javax.ws.rs.core.Response |
Server.addOneColumn(String db,
String table,
String column,
ColumnDesc desc)
Create a column in an hcat table.
|
javax.ws.rs.core.Response |
HcatDelegator.addOneColumn(String user,
String db,
String table,
ColumnDesc desc)
Add one column.
|
javax.ws.rs.core.Response |
Server.addOnePartition(String db,
String table,
String partition,
PartitionDesc desc)
Create a partition in an hcat table.
|
javax.ws.rs.core.Response |
HcatDelegator.addOnePartition(String user,
String db,
String table,
PartitionDesc desc)
Add one partition.
|
javax.ws.rs.core.Response |
Server.addOneTableProperty(String db,
String table,
String property,
TablePropertyDesc desc)
Add a single property on an hcat table.
|
javax.ws.rs.core.Response |
HcatDelegator.addOneTableProperty(String user,
String db,
String table,
TablePropertyDesc desc)
Add one table property.
|
javax.ws.rs.core.Response |
Server.createDatabase(String db,
DatabaseDesc desc)
Create a database
|
javax.ws.rs.core.Response |
HcatDelegator.createDatabase(String user,
DatabaseDesc desc)
Create a database with the given name
|
javax.ws.rs.core.Response |
Server.createTable(String db,
String table,
TableDesc desc)
Create a new table.
|
javax.ws.rs.core.Response |
HcatDelegator.createTable(String user,
String db,
TableDesc desc)
Create a table.
|
javax.ws.rs.core.Response |
Server.createTableLike(String db,
String existingTable,
String newTable,
TableLikeDesc desc)
Create a new table like another table.
|
javax.ws.rs.core.Response |
HcatDelegator.createTableLike(String user,
String db,
TableLikeDesc desc)
Create a table like another.
|
ExecBean |
Server.ddl(String exec,
String group,
String permissions)
Execute an hcat ddl expression on the local box.
|
javax.ws.rs.core.Response |
Server.descColumn(String db,
String table,
String column)
Describe a single column in an hcat table.
|
javax.ws.rs.core.Response |
Server.descDatabase(String db,
String format)
Describe a database
|
javax.ws.rs.core.Response |
HcatDelegator.descDatabase(String user,
String db,
boolean extended)
Return a json description of the database.
|
javax.ws.rs.core.Response |
HcatDelegator.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 |
HcatDelegator.descOneColumn(String user,
String db,
String table,
String column)
Return a json description of one column.
|
javax.ws.rs.core.Response |
HcatDelegator.descOnePartition(String user,
String db,
String table,
String partition)
Return a json description of one partition.
|
javax.ws.rs.core.Response |
Server.descOneTableProperty(String db,
String table,
String property)
Describe a single property on an hcat table.
|
javax.ws.rs.core.Response |
Server.descPartition(String db,
String table,
String partition)
Describe a single partition in an hcat table.
|
javax.ws.rs.core.Response |
Server.descTable(String db,
String table,
String format)
Describe an hcat table.
|
javax.ws.rs.core.Response |
HcatDelegator.descTable(String user,
String db,
String table,
boolean extended)
Return a json description of the table.
|
javax.ws.rs.core.Response |
HcatDelegator.descTableProperty(String user,
String db,
String table,
String property)
Describe one table property.
|
javax.ws.rs.core.Response |
Server.dropDatabase(String db,
boolean ifExists,
String option,
String group,
String permissions)
Drop a database
|
javax.ws.rs.core.Response |
HcatDelegator.dropDatabase(String user,
String db,
boolean ifExists,
String option,
String group,
String permissions)
Drop the given database
|
javax.ws.rs.core.Response |
Server.dropPartition(String db,
String table,
String partition,
boolean ifExists,
String group,
String permissions)
Drop a partition in an hcat table.
|
javax.ws.rs.core.Response |
HcatDelegator.dropPartition(String user,
String db,
String table,
String partition,
boolean ifExists,
String group,
String permissions)
Drop a partition.
|
javax.ws.rs.core.Response |
Server.dropTable(String db,
String table,
boolean ifExists,
String group,
String permissions)
Drop an hcat table.
|
javax.ws.rs.core.Response |
HcatDelegator.dropTable(String user,
String db,
String table,
boolean ifExists,
String group,
String permissions)
Drop a table.
|
EnqueueBean |
LauncherDelegator.enqueueController(String user,
Map<String,Object> userArgs,
String callback,
List<String> args)
Enqueue the TempletonControllerJob directly calling doAs.
|
EnqueueBean |
Server.hive(String execute,
String srcFile,
List<String> hiveArgs,
String otherFiles,
List<String> defines,
String statusdir,
String callback,
boolean enablelog,
Boolean enablejobreconnect)
Run a Hive job.
|
javax.ws.rs.core.Response |
Server.listColumns(String db,
String table)
List the columns in an hcat table.
|
javax.ws.rs.core.Response |
HcatDelegator.listColumns(String user,
String db,
String table)
Return a json description of the columns.
|
javax.ws.rs.core.Response |
Server.listDatabases(String dbPattern)
List all databases, or those that match a pattern.
|
javax.ws.rs.core.Response |
HcatDelegator.listDatabases(String user,
String dbPattern)
Return a json "show databases like".
|
javax.ws.rs.core.Response |
Server.listPartitions(String db,
String table)
List all the partitions in an hcat table.
|
javax.ws.rs.core.Response |
HcatDelegator.listPartitions(String user,
String db,
String table)
Return a json description of the partitions.
|
javax.ws.rs.core.Response |
Server.listTableProperties(String db,
String table)
List all the properties on an hcat table.
|
javax.ws.rs.core.Response |
HcatDelegator.listTableProperties(String user,
String db,
String table)
List the table properties.
|
javax.ws.rs.core.Response |
Server.listTables(String db,
String tablePattern)
List all the tables in an hcat database.
|
javax.ws.rs.core.Response |
HcatDelegator.listTables(String user,
String db,
String tablePattern)
Return a json "show table like".
|
EnqueueBean |
Server.mapReduceJar(String jar,
String mainClass,
String libjars,
String files,
List<String> args,
List<String> defines,
String statusdir,
String callback,
boolean usesHcatalog,
boolean enablelog,
Boolean enablejobreconnect)
Run a MapReduce Jar job.
|
EnqueueBean |
Server.mapReduceStreaming(List<String> inputs,
String inputreader,
String output,
String mapper,
String reducer,
String combiner,
List<String> fileList,
String files,
List<String> defines,
List<String> cmdenvs,
List<String> args,
String statusdir,
String callback,
boolean enablelog,
Boolean enablejobreconnect)
Run a MapReduce Streaming job.
|
EnqueueBean |
Server.pig(String execute,
String srcFile,
List<String> pigArgs,
String otherFiles,
String statusdir,
String callback,
boolean usesHcatalog,
boolean enablelog,
Boolean enablejobreconnect)
Run a Pig job.
|
javax.ws.rs.core.Response |
Server.renameTable(String db,
String oldTable,
String newTable,
String group,
String permissions)
Rename an hcat table.
|
javax.ws.rs.core.Response |
HcatDelegator.renameTable(String user,
String db,
String oldTable,
String newTable,
String group,
String permissions)
Rename a table.
|
ExecBean |
ExecServiceImpl.run(String program,
List<String> args,
Map<String,String> env)
Run the program synchronously as the given user.
|
ExecBean |
ExecService.run(String program,
List<String> args,
Map<String,String> env) |
EnqueueBean |
StreamingDelegator.run(String user,
Map<String,Object> userArgs,
List<String> inputs,
String inputreader,
String output,
String mapper,
String reducer,
String combiner,
List<String> fileList,
String files,
List<String> defines,
List<String> cmdenvs,
List<String> jarArgs,
String statusdir,
String callback,
String completedUrl,
boolean enableLog,
Boolean enableJobReconnect,
LauncherDelegator.JobType jobType) |
EnqueueBean |
HiveDelegator.run(String user,
Map<String,Object> userArgs,
String execute,
String srcFile,
List<String> defines,
List<String> hiveArgs,
String otherFiles,
String statusdir,
String callback,
String completedUrl,
boolean enablelog,
Boolean enableJobReconnect) |
EnqueueBean |
PigDelegator.run(String user,
Map<String,Object> userArgs,
String execute,
String srcFile,
List<String> pigArgs,
String otherFiles,
String statusdir,
String callback,
boolean usesHcatalog,
String completedUrl,
boolean enablelog,
Boolean enableJobReconnect) |
EnqueueBean |
JarDelegator.run(String user,
Map<String,Object> userArgs,
String jar,
String mainClass,
String libjars,
String files,
List<String> jarArgs,
List<String> defines,
String statusdir,
String callback,
boolean usesHcatalog,
String completedUrl,
boolean enablelog,
Boolean enableJobReconnect,
LauncherDelegator.JobType jobType) |
EnqueueBean |
SqoopDelegator.run(String user,
Map<String,Object> userArgs,
String command,
String optionsFile,
String otherFiles,
String statusdir,
String callback,
String completedUrl,
boolean enablelog,
Boolean enableJobReconnect,
String libdir) |
ExecBean |
HcatDelegator.run(String user,
String exec,
boolean format,
String group,
String permissions)
Run the local hcat executable.
|
EnqueueBean |
Server.sqoop(String command,
String optionsFile,
String libdir,
String otherFiles,
String statusdir,
String callback,
boolean enablelog,
Boolean enablejobreconnect)
Run a Sqoop job.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.