| Package | Description |
|---|---|
| com.asakusafw.testdriver.executor |
Executes test tasks.
|
| com.asakusafw.testdriver.inprocess |
In-process Hadoop task executor.
|
| com.asakusafw.testdriver.windgate.inprocess |
Emulation mode API for WindGate.
|
| com.asakusafw.workflow.cli.run |
Implementations of
run command. |
| com.asakusafw.workflow.executor |
Provides workflow executors.
|
| com.asakusafw.workflow.executor.basic |
Basic implementations of workflow executions.
|
| com.asakusafw.workflow.hadoop |
Asakusa workflow Hadoop bridge classes.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultCommandTaskExecutor
Executes
CommandTaskInfo via fork/exec. |
class |
DefaultDeleteTaskExecutor
Executes
DeleteTaskInfo directly. |
class |
DefaultHadoopTaskExecutor
Executes
HadoopTaskInfo via fork/exec. |
class |
VoidDeleteTaskExecutor
Accepts
DeleteTaskInfo and does nothing. |
| Modifier and Type | Class and Description |
|---|---|
class |
InProcessHadoopTaskExecutor
Executes
HadoopTaskInfo in this process. |
| Modifier and Type | Class and Description |
|---|---|
class |
InProcessWindGateFinalizeTaskExecutor
In-process
TaskExecutor for windgate/bin/finalize. |
class |
InProcessWindGateProcessTaskExecutor
In-process
TaskExecutor for windgate/bin/process. |
| Modifier and Type | Method and Description |
|---|---|
List<TaskExecutor> |
ExecutorParameter.getTaskExecutors(ExecutionContext context)
Returns the task executors.
|
| Modifier and Type | Method and Description |
|---|---|
static Collection<TaskExecutor> |
TaskExecutors.loadDefaults(ClassLoader serviceLoader)
Returns the default task executor objects via SPI.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BasicCommandTaskExecutor
Executes
CommandTaskInfo via fork/exec. |
class |
BasicDeleteTaskExecutor
A basic implementation of
TaskExecutor for DeleteTaskInfo. |
| Constructor and Description |
|---|
BasicJobflowExecutor(TaskExecutor... taskExecutors)
Creates a new instance.
|
| Constructor and Description |
|---|
BasicJobflowExecutor(Collection<? extends TaskExecutor> taskExecutors)
Creates a new instance.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BridgeDeleteTaskExecutor
Executes delete tasks via
tools/bin/libexec/workflow/hadoop-bridge. |
class |
BridgeHadoopTaskExecutor
Executes hadoop tasks via
tools/bin/libexec/workflow/hadoop-bridge. |
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.