public class FsActionExecutor extends ActionExecutor
ActionExecutor.Context
CONF_PREFIX, ERROR_OTHER, MAX_RETRIES, requiresNNJT, RETRY_INTERVAL
Constructor and Description |
---|
FsActionExecutor() |
Modifier and Type | Method and Description |
---|---|
void |
check(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
Check if an action has completed.
|
void |
delete(ActionExecutor.Context context,
org.apache.hadoop.fs.Path path)
Delete path
|
void |
delete(ActionExecutor.Context context,
XConfiguration fsConf,
org.apache.hadoop.fs.Path nameNodePath,
org.apache.hadoop.fs.Path path)
Delete path
|
void |
delete(String user,
String group,
org.apache.hadoop.fs.Path path)
Delete path
|
void |
end(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
End an action after it has executed.
|
org.apache.hadoop.fs.Path |
getRecoveryPath(ActionExecutor.Context context) |
boolean |
isCompleted(String externalStatus)
Return if the external status indicates that the action has completed.
|
void |
kill(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
Kill an action.
|
void |
move(ActionExecutor.Context context,
org.apache.hadoop.fs.Path source,
org.apache.hadoop.fs.Path target,
boolean recovery)
Move source to target
|
void |
move(ActionExecutor.Context context,
XConfiguration fsConf,
org.apache.hadoop.fs.Path nameNodePath,
org.apache.hadoop.fs.Path source,
org.apache.hadoop.fs.Path target,
boolean recovery)
Move source to target
|
void |
start(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
Start an action.
|
convertException, disableInit, enableInit, getActionDir, getActionDirPath, getActionSignal, getMaxRetries, getOozieConf, getOozieRuntimeDir, getOozieSystemId, getRetryInterval, getType, initActionType, registerError, resetInitInfo, setMaxRetries, setRetryInterval
public FsActionExecutor()
public void delete(ActionExecutor.Context context, org.apache.hadoop.fs.Path path) throws ActionExecutorException
context
- path
- ActionExecutorException
public void delete(ActionExecutor.Context context, XConfiguration fsConf, org.apache.hadoop.fs.Path nameNodePath, org.apache.hadoop.fs.Path path) throws ActionExecutorException
context
- fsConf
- nameNodePath
- path
- ActionExecutorException
public void delete(String user, String group, org.apache.hadoop.fs.Path path) throws ActionExecutorException
user
- group
- path
- ActionExecutorException
public void move(ActionExecutor.Context context, org.apache.hadoop.fs.Path source, org.apache.hadoop.fs.Path target, boolean recovery) throws ActionExecutorException
context
- source
- target
- recovery
- ActionExecutorException
public void move(ActionExecutor.Context context, XConfiguration fsConf, org.apache.hadoop.fs.Path nameNodePath, org.apache.hadoop.fs.Path source, org.apache.hadoop.fs.Path target, boolean recovery) throws ActionExecutorException
context
- fsConf
- nameNodePath
- source
- target
- recovery
- ActionExecutorException
public void check(ActionExecutor.Context context, org.apache.oozie.client.WorkflowAction action) throws ActionExecutorException
ActionExecutor
ActionExecutor.Context.setExecutionData(java.lang.String, java.util.Properties)
method must be called within this method. If the action
has not completed, the ActionExecutor.Context.setExternalStatus(java.lang.String)
method must be called within this method.check
in class ActionExecutor
context
- executor context.action
- the action to end.ActionExecutorException
- thrown if the action could not be checked.public void kill(ActionExecutor.Context context, org.apache.oozie.client.WorkflowAction action) throws ActionExecutorException
ActionExecutor
ActionExecutor.Context.setEndData(org.apache.oozie.client.WorkflowAction.Status, java.lang.String)
method must be called within this method.kill
in class ActionExecutor
context
- executor context.action
- the action to kill.ActionExecutorException
- thrown if the action could not be killed.public void start(ActionExecutor.Context context, org.apache.oozie.client.WorkflowAction action) throws ActionExecutorException
ActionExecutor
ActionExecutor.Context.setStartData(java.lang.String, java.lang.String, java.lang.String)
method must be called within this method. If the
action has completed, the ActionExecutor.Context.setExecutionData(java.lang.String, java.util.Properties)
method must be called within this method.start
in class ActionExecutor
context
- executor context.action
- the action to start.ActionExecutorException
- thrown if the action could not start.public void end(ActionExecutor.Context context, org.apache.oozie.client.WorkflowAction action) throws ActionExecutorException
ActionExecutor
ActionExecutor.Context.setEndData(org.apache.oozie.client.WorkflowAction.Status, java.lang.String)
method must be called within this
method.end
in class ActionExecutor
context
- executor context.action
- the action to end.ActionExecutorException
- thrown if the action could not end.public boolean isCompleted(String externalStatus)
ActionExecutor
isCompleted
in class ActionExecutor
externalStatus
- external status to check.public org.apache.hadoop.fs.Path getRecoveryPath(ActionExecutor.Context context) throws HadoopAccessorException, IOException, URISyntaxException
context
- HadoopAccessorException
IOException
URISyntaxException
Copyright © 2014 Apache Software Foundation. All Rights Reserved.