Package | Description |
---|---|
org.apache.hive.hcatalog.templeton |
Modifier and Type | Method and Description |
---|---|
EnqueueBean |
LauncherDelegator.enqueueController(String user,
Map<String,Object> userArgs,
String callback,
List<String> args) |
EnqueueBean |
LauncherDelegator.enqueueJob(String user,
Map<String,Object> userArgs,
String callback,
List<String> args,
TempletonControllerJob controllerJob)
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.
|
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.
|
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) |
EnqueueBean |
Server.sqoop(String command,
String optionsFile,
String libdir,
String otherFiles,
String statusdir,
String callback,
boolean enablelog,
Boolean enablejobreconnect)
Run a Sqoop job.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.