| Package | Description |
|---|---|
| org.apache.oozie.client |
| Modifier and Type | Method and Description |
|---|---|
org.json.simple.JSONObject |
OozieClient.bulkModifyJobs(java.lang.String actionType,
java.lang.String filter,
java.lang.String jobType,
int start,
int len) |
T |
OozieClient.ClientCallable.call() |
protected abstract T |
OozieClient.ClientCallable.call(java.net.HttpURLConnection conn) |
protected java.util.Map<java.lang.String,java.lang.String> |
OozieClient.MapClientCallable.call(java.net.HttpURLConnection conn) |
void |
OozieClient.change(java.lang.String jobId,
java.lang.String changeValue)
Change a coordinator job.
|
protected java.net.HttpURLConnection |
AuthOozieClient.createConnection(java.net.URL url,
java.lang.String method)
Create an authenticated connection to the Oozie server.
|
protected java.net.HttpURLConnection |
OozieClient.createConnection(java.net.URL url,
java.lang.String method)
Create http connection to oozie server.
|
java.lang.String |
OozieClient.dryrun(java.util.Properties conf)
dryrun for a given job
|
protected org.apache.hadoop.security.authentication.client.Authenticator |
AuthOozieClient.getAuthenticator()
Return the Hadoop-auth Authenticator to use.
|
java.util.Map<java.lang.String,java.lang.String> |
OozieClient.getAvailableOozieServers()
Return the list of available Oozie servers.
|
java.util.List<BulkResponse> |
OozieClient.getBulkInfo(java.lang.String filter,
int start,
int len) |
BundleJob |
OozieClient.getBundleJobInfo(java.lang.String jobId)
Get the info of a bundle job.
|
java.util.List<BundleJob> |
OozieClient.getBundleJobsInfo(java.lang.String filter,
int start,
int len)
Return the info of the bundle jobs that match the filter.
|
CoordinatorAction |
OozieClient.getCoordActionInfo(java.lang.String actionId)
Get the info of a coordinator action.
|
CoordinatorJob |
OozieClient.getCoordJobInfo(java.lang.String jobId)
Get the info of a coordinator job.
|
CoordinatorJob |
OozieClient.getCoordJobInfo(java.lang.String jobId,
java.lang.String filter,
int start,
int len)
Get the info of a coordinator job and subset actions.
|
CoordinatorJob |
OozieClient.getCoordJobInfo(java.lang.String jobId,
java.lang.String filter,
int start,
int len,
java.lang.String order)
Get the info of a coordinator job and subset actions.
|
java.util.List<CoordinatorJob> |
OozieClient.getCoordJobsInfo(java.lang.String filter,
int start,
int len)
Return the info of the coordinator jobs that match the filter.
|
OozieClient.Instrumentation |
OozieClient.getInstrumentation()
Return the Oozie instrumentation.
|
java.util.Map<java.lang.String,java.lang.String> |
OozieClient.getJavaSystemProperties()
Return the Oozie Java system properties.
|
JMSConnectionInfo |
OozieClient.getJMSConnectionInfo()
Get the JMS Connection info
|
java.lang.String |
OozieClient.getJMSTopicName(java.lang.String jobId)
Gets the JMS topic name for a particular job
|
java.lang.String |
OozieClient.getJobDefinition(java.lang.String jobId)
Get the definition of a workflow job.
|
java.lang.String |
OozieClient.getJobId(java.lang.String externalId)
Return the workflow job Id for an external Id.
|
WorkflowJob |
OozieClient.getJobInfo(java.lang.String jobId)
Get the info of a workflow job.
|
WorkflowJob |
OozieClient.getJobInfo(java.lang.String jobId,
int start,
int len)
Get the info of a workflow job and subset actions.
|
java.lang.String |
OozieClient.getJobLog(java.lang.String jobId)
Get the log of a workflow job.
|
void |
OozieClient.getJobLog(java.lang.String jobId,
java.lang.String logRetrievalType,
java.lang.String logRetrievalScope,
java.io.PrintStream ps)
Get the log of a job.
|
void |
OozieClient.getJobLog(java.lang.String jobId,
java.lang.String logRetrievalType,
java.lang.String logRetrievalScope,
java.lang.String logFilter,
java.io.PrintStream ps)
Get the log of a job.
|
java.util.List<WorkflowJob> |
OozieClient.getJobsInfo(java.lang.String filter)
Return the info of the workflow jobs that match the filter.
|
java.util.List<WorkflowJob> |
OozieClient.getJobsInfo(java.lang.String filter,
int start,
int len)
Return the info of the workflow jobs that match the filter.
|
OozieClient.Metrics |
OozieClient.getMetrics()
Return the Oozie metrics.
|
java.util.Map<java.lang.String,java.lang.String> |
OozieClient.getOSEnv()
Return the Oozie system OS environment.
|
java.lang.String |
OozieClient.getProtocolUrl()
Return the Oozie URL used by the client and server for WS communications.
|
java.util.List<java.lang.String> |
OozieClient.getQueueDump()
Return the Oozie queue's commands' dump
|
java.lang.String |
OozieClient.getServerBuildVersion()
Return the Oozie server build version.
|
java.util.Map<java.lang.String,java.lang.String> |
OozieClient.getServerConfiguration()
Return the Oozie system configuration.
|
void |
OozieClient.getSlaInfo(int start,
int len,
java.lang.String filter)
Print sla info about coordinator and workflow jobs and actions.
|
java.lang.String |
OozieClient.getStatus(java.lang.String jobId)
Gets the status for a particular job (Workflow Job ID, Coordinator Job ID, Coordinator Action ID, or Bundle Job ID).
|
OozieClient.SYSTEM_MODE |
OozieClient.getSystemMode()
Returns if Oozie is in safe mode or not.
|
java.util.List<WorkflowJob> |
OozieClient.getWfsForCoordAction(java.lang.String coordActionId) |
WorkflowAction |
OozieClient.getWorkflowActionInfo(java.lang.String actionId)
Get the info of a workflow action.
|
java.util.List<CoordinatorAction> |
OozieClient.ignore(java.lang.String jobId,
java.lang.String scope)
Ignore a coordinator job.
|
void |
OozieClient.kill(java.lang.String jobId)
Kill a workflow/coord/bundle job.
|
java.util.List<CoordinatorAction> |
OozieClient.kill(java.lang.String jobId,
java.lang.String rangeType,
java.lang.String scope)
Kill coordinator actions
|
org.json.simple.JSONObject |
OozieClient.killJobs(java.lang.String filter,
java.lang.String jobType,
int start,
int len) |
java.lang.String |
OozieClient.listShareLib(java.lang.String sharelibKey) |
void |
OozieClient.pollJob(java.lang.String id,
int timeout,
int interval,
boolean verbose)
Poll a job (Workflow Job ID, Coordinator Job ID, Coordinator Action ID, or Bundle Job ID) and return when it has reached a
terminal state.
|
void |
OozieClient.reRun(java.lang.String jobId,
java.util.Properties conf)
Rerun a workflow job.
|
java.lang.Void |
OozieClient.reRunBundle(java.lang.String jobId,
java.lang.String coordScope,
java.lang.String dateScope,
boolean refresh,
boolean noCleanup)
Rerun bundle coordinators.
|
java.util.List<CoordinatorAction> |
OozieClient.reRunCoord(java.lang.String jobId,
java.lang.String rerunType,
java.lang.String scope,
boolean refresh,
boolean noCleanup)
Rerun coordinator actions.
|
java.util.List<CoordinatorAction> |
OozieClient.reRunCoord(java.lang.String jobId,
java.lang.String rerunType,
java.lang.String scope,
boolean refresh,
boolean noCleanup,
boolean failed)
Rerun coordinator actions with failed option.
|
void |
OozieClient.resume(java.lang.String jobId)
Resume a workflow job.
|
org.json.simple.JSONObject |
OozieClient.resumeJobs(java.lang.String filter,
java.lang.String jobType,
int start,
int len) |
java.lang.String |
OozieClient.run(java.util.Properties conf)
Submit and start a workflow job.
|
void |
OozieClient.setSystemMode(OozieClient.SYSTEM_MODE status)
Enable or disable safe mode.
|
void |
OozieClient.start(java.lang.String jobId)
Start a workflow job.
|
java.lang.String |
OozieClient.submit(java.util.Properties conf)
Submit a workflow job.
|
java.lang.String |
XOozieClient.submitMapReduce(java.util.Properties conf)
Submit a Map/Reduce job via HTTP.
|
java.lang.String |
XOozieClient.submitPig(java.util.Properties conf,
java.lang.String pigScriptFile,
java.lang.String[] pigArgs)
Deprecated.
|
java.lang.String |
XOozieClient.submitScriptLanguage(java.util.Properties conf,
java.lang.String scriptFile,
java.lang.String[] args,
java.lang.String jobType)
Submit a Pig or Hive job via HTTP.
|
java.lang.String |
XOozieClient.submitScriptLanguage(java.util.Properties conf,
java.lang.String scriptFile,
java.lang.String[] args,
java.lang.String[] params,
java.lang.String jobType)
Submit a Pig or Hive job via HTTP.
|
java.lang.String |
XOozieClient.submitSqoop(java.util.Properties conf,
java.lang.String[] command,
java.lang.String[] args)
Submit a Sqoop job via HTTP.
|
void |
OozieClient.suspend(java.lang.String jobId)
Suspend a workflow job.
|
org.json.simple.JSONObject |
OozieClient.suspendJobs(java.lang.String filter,
java.lang.String jobType,
int start,
int len) |
java.lang.String |
OozieClient.updateCoord(java.lang.String jobId,
java.util.Properties conf,
java.lang.String dryrun,
java.lang.String showDiff)
Update coord definition.
|
java.lang.String |
OozieClient.updateCoord(java.lang.String jobId,
java.lang.String dryrun,
java.lang.String showDiff)
Update coord definition without properties.
|
java.lang.String |
OozieClient.updateShareLib() |
void |
OozieClient.validateWSVersion()
Validate that the Oozie client and server instances are protocol compatible.
|
java.lang.String |
OozieClient.validateXML(java.lang.String file)
Return the workflow application is valid.
|
Copyright © 2018 Apache Software Foundation. All Rights Reserved.