Package | Description |
---|---|
com.asakusafw.testdriver.executor |
Executes test tasks.
|
com.asakusafw.workflow.cli.common |
Common classes for CLI.
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
TaskExecutorContextAdapter
A bridge implementation of context for
TaskExecutor . |
Modifier and Type | Method and Description |
---|---|
ExecutionContext |
ExecutionContextParameter.getExecutionContext()
Returns the execution context.
|
Modifier and Type | Method and Description |
---|---|
static List<String> |
WorkflowParameter.getAvailableApplications(ExecutionContext context)
Returns a list of available batch application names on the current context.
|
BatchInfo |
WorkflowParameter.getBatchInfo(ExecutionContext context)
Returns workflow information.
|
Modifier and Type | Method and Description |
---|---|
BatchExecutor |
ExecutorParameter.getBatchExecutor(ExecutionContext context)
Returns the batch executor.
|
JobflowExecutor |
ExecutorParameter.getJobflowExecutor(ExecutionContext context)
Returns the jobflow executor.
|
List<TaskExecutor> |
ExecutorParameter.getTaskExecutors(ExecutionContext context)
Returns the task executors.
|
Modifier and Type | Interface and Description |
---|---|
interface |
TaskExecutionContext
Represents a context of
TaskExecutor . |
Modifier and Type | Method and Description |
---|---|
default void |
BatchExecutor.execute(ExecutionContext context,
BatchInfo batch)
Executes the given batch without any batch arguments.
|
void |
BatchExecutor.execute(ExecutionContext context,
BatchInfo batch,
Map<String,String> arguments)
Executes the given batch.
|
static Optional<Path> |
TaskExecutors.findApplicationHome(ExecutionContext context)
Returns the batch application installation base path.
|
static Optional<Path> |
TaskExecutors.findCoreConfigurationFile(ExecutionContext context)
Returns the core configuration file.
|
static Optional<URL> |
TaskExecutors.findCoreConfigurationUrl(ExecutionContext context)
Returns the core configuration URL only if it exists.
|
static Set<Path> |
TaskExecutors.findCoreLibraries(ExecutionContext context)
Returns the framework core library files.
|
static Set<Path> |
TaskExecutors.findExtensionLibraries(ExecutionContext context)
Returns the framework extension library files.
|
static Optional<Path> |
TaskExecutors.findFrameworkFile(ExecutionContext context,
String location)
Returns a framework file.
|
static Optional<Path> |
TaskExecutors.findFrameworkHome(ExecutionContext context)
Returns the framework installation path.
|
static Set<Path> |
TaskExecutors.findFrameworkLibraries(ExecutionContext context,
String location)
Returns the library files on the framework directory.
|
static Set<Path> |
TaskExecutors.findHadoopEmbeddedLibraries(ExecutionContext context)
Returns the Hadoop embedded library files.
|
static Path |
TaskExecutors.getUserHome(ExecutionContext context)
Returns the current user home directory.
|
static String |
TaskExecutors.getUserName(ExecutionContext context)
Returns the current user name.
|
Modifier and Type | Class and Description |
---|---|
class |
BasicExecutionContext
A basic implementation of
ExecutionContext . |
class |
BasicTaskExecutionContext
A basic implementation of
TaskExecutionContext . |
Modifier and Type | Method and Description |
---|---|
void |
BasicBatchExecutor.execute(ExecutionContext context,
BatchInfo batch,
Map<String,String> arguments) |
static CommandLauncher |
BasicCommandTaskExecutor.getCommandLauncher(ExecutionContext context)
Returns a
CommandLauncher . |
static CommandLauncher |
BasicCommandTaskExecutor.getCommandLauncher(ExecutionContext context,
BasicCommandLauncher.OutputConsumer output)
Returns a
CommandLauncher . |
Constructor and Description |
---|
BasicTaskExecutionContext(ExecutionContext parent,
String batchId,
String flowId,
String executionId,
Map<String,String> batchArguments)
Creates a new instance.
|
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.