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.executor |
Provides workflow executors.
|
com.asakusafw.workflow.executor.basic |
Basic implementations of workflow executions.
|
com.asakusafw.workflow.hadoop |
Asakusa workflow Hadoop bridge classes.
|
com.asakusafw.workflow.model |
Represents workflow models.
|
com.asakusafw.workflow.model.basic |
Basic implementations of workflow models.
|
Modifier and Type | Method and Description |
---|---|
void |
VoidDeleteTaskExecutor.execute(TaskExecutionContext context,
TaskInfo task) |
void |
DefaultHadoopTaskExecutor.execute(TaskExecutionContext context,
TaskInfo task) |
boolean |
VoidDeleteTaskExecutor.isSupported(TaskExecutionContext context,
TaskInfo task) |
boolean |
DefaultHadoopTaskExecutor.isSupported(TaskExecutionContext context,
TaskInfo task) |
boolean |
DefaultCommandTaskExecutor.isSupported(TaskExecutionContext context,
TaskInfo task) |
Modifier and Type | Method and Description |
---|---|
void |
InProcessHadoopTaskExecutor.execute(TaskExecutionContext context,
TaskInfo task) |
boolean |
InProcessHadoopTaskExecutor.isSupported(TaskExecutionContext context,
TaskInfo task) |
Modifier and Type | Method and Description |
---|---|
void |
InProcessWindGateFinalizeTaskExecutor.execute(TaskExecutionContext context,
TaskInfo task) |
void |
InProcessWindGateProcessTaskExecutor.execute(TaskExecutionContext context,
TaskInfo task) |
boolean |
InProcessWindGateFinalizeTaskExecutor.isSupported(TaskExecutionContext context,
TaskInfo task) |
boolean |
InProcessWindGateProcessTaskExecutor.isSupported(TaskExecutionContext context,
TaskInfo task) |
Modifier and Type | Method and Description |
---|---|
void |
TaskExecutor.execute(TaskExecutionContext context,
TaskInfo task)
Executes a task.
|
boolean |
TaskExecutor.isSupported(TaskExecutionContext context,
TaskInfo task)
Returns whether this executor supports executing the target task.
|
Modifier and Type | Method and Description |
---|---|
void |
BasicCommandTaskExecutor.execute(TaskExecutionContext context,
TaskInfo task) |
void |
BasicDeleteTaskExecutor.execute(TaskExecutionContext context,
TaskInfo task) |
boolean |
BasicCommandTaskExecutor.isSupported(TaskExecutionContext context,
TaskInfo task) |
boolean |
BasicDeleteTaskExecutor.isSupported(TaskExecutionContext context,
TaskInfo task) |
Modifier and Type | Method and Description |
---|---|
void |
BridgeHadoopTaskExecutor.execute(TaskExecutionContext context,
TaskInfo task) |
boolean |
BridgeDeleteTaskExecutor.isSupported(TaskExecutionContext context,
TaskInfo task) |
boolean |
BridgeHadoopTaskExecutor.isSupported(TaskExecutionContext context,
TaskInfo task) |
Modifier and Type | Interface and Description |
---|---|
interface |
CommandTaskInfo
Represents a command task.
|
interface |
DeleteTaskInfo
Deletes files.
|
interface |
HadoopTaskInfo
Represents a Hadoop task.
|
Modifier and Type | Method and Description |
---|---|
Collection<? extends TaskInfo> |
JobflowInfo.getTasks(TaskInfo.Phase phase)
Returns tasks of this jobflow.
|
Modifier and Type | Class and Description |
---|---|
class |
BasicCommandTaskInfo
Represents a command task.
|
class |
BasicDeleteTaskInfo
A basic implementation of
DeleteTaskInfo . |
class |
BasicHadoopTaskInfo
A basic implementation of
HadoopTaskInfo . |
class |
BasicTaskInfo
An abstract implementation of
TaskInfo . |
Modifier and Type | Method and Description |
---|---|
Collection<? extends TaskInfo> |
BasicJobflowInfo.getTasks(TaskInfo.Phase phase) |
Modifier and Type | Method and Description |
---|---|
void |
BasicJobflowInfo.addTask(TaskInfo.Phase phase,
TaskInfo task)
Adds a task.
|
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.