Modifier and Type | Class and Description |
---|---|
class |
ControlNodeActionExecutor
Base action executor for control nodes: START/END/KILL/FORK/JOIN
|
class |
EndActionExecutor
Action executor for END control node.
|
class |
ForkActionExecutor
Action executor for FORK control node.
|
class |
JoinActionExecutor
Action executor for JOIN control node.
|
class |
KillActionExecutor
Action executor for KILL control node.
|
class |
StartActionExecutor
Action executor for START control node.
|
Modifier and Type | Class and Description |
---|---|
class |
DecisionActionExecutor |
Modifier and Type | Class and Description |
---|---|
class |
EmailActionExecutor
Email action executor.
|
Modifier and Type | Class and Description |
---|---|
class |
DistcpActionExecutor |
class |
FsActionExecutor
File system action executor.
|
class |
Hive2ActionExecutor |
class |
HiveActionExecutor |
class |
JavaActionExecutor |
class |
MapReduceActionExecutor |
class |
PigActionExecutor |
class |
ScriptLanguageActionExecutor |
class |
ShellActionExecutor |
class |
SparkActionExecutor |
class |
SqoopActionExecutor |
Modifier and Type | Class and Description |
---|---|
class |
SubWorkflowActionExecutor |
Modifier and Type | Class and Description |
---|---|
class |
SshActionExecutor
Ssh action executor.
|
Modifier and Type | Method and Description |
---|---|
protected void |
ActionXCommand.handleError(ActionExecutor.Context context,
ActionExecutor executor,
String message,
boolean isStart,
WorkflowAction.Status status)
Takes care of errors.
|
protected void |
ForkedActionStartXCommand.handleNonTransient(ActionExecutor.Context context,
ActionExecutor executor,
WorkflowAction.Status status) |
protected void |
ActionXCommand.handleNonTransient(ActionExecutor.Context context,
ActionExecutor executor,
WorkflowAction.Status status)
Takes care of non transient failures.
|
protected boolean |
ActionXCommand.handleTransient(ActionExecutor.Context context,
ActionExecutor executor,
WorkflowAction.Status status)
Takes care of Transient failures.
|
Modifier and Type | Method and Description |
---|---|
ActionExecutor |
ActionService.getExecutor(String actionType) |
Modifier and Type | Method and Description |
---|---|
void |
ActionService.registerAndInitExecutor(Class<? extends ActionExecutor> klass) |
Copyright © 2018 Apache Software Foundation. All rights reserved.