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.