Uses of Interface
com.asakusafw.workflow.executor.TaskExecutionContext

Packages that use TaskExecutionContext

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.

Uses of TaskExecutionContext in com.asakusafw.testdriver.executor

Classes in com.asakusafw.testdriver.executor that implement TaskExecutionContext

Modifier and Type	Class and Description
class	TaskExecutorContextAdapter A bridge implementation of context for TaskExecutor.

Methods in com.asakusafw.testdriver.executor with parameters of type TaskExecutionContext

Modifier and Type	Method and Description
static void	DefaultCommandTaskExecutor.checkSupported(TaskExecutionContext context, CommandTaskInfo task) Checks if this executor can execute the given task, or raise an exception.
static void	DefaultHadoopTaskExecutor.checkSupported(TaskExecutionContext context, HadoopTaskInfo task) Checks if this executor can execute the given task, or raise an exception.
protected void	DefaultDeleteTaskExecutor.deleteOnHadoopFileSystem(TaskExecutionContext context, String path)
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)

Uses of TaskExecutionContext in com.asakusafw.testdriver.inprocess

Methods in com.asakusafw.testdriver.inprocess with parameters of type TaskExecutionContext

Modifier and Type	Method and Description
void	InProcessHadoopTaskExecutor.execute(TaskExecutionContext context, TaskInfo task)
boolean	InProcessHadoopTaskExecutor.isSupported(TaskExecutionContext context, TaskInfo task)

Uses of TaskExecutionContext in com.asakusafw.testdriver.windgate.inprocess

Methods in com.asakusafw.testdriver.windgate.inprocess with parameters of type TaskExecutionContext

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)

Uses of TaskExecutionContext in com.asakusafw.workflow.executor

Methods in com.asakusafw.workflow.executor with parameters of type TaskExecutionContext

Modifier and Type	Method and Description
void	JobflowExecutor.execute(TaskExecutionContext context, JobflowInfo jobflow) Executes the given jobflow.
void	TaskExecutor.execute(TaskExecutionContext context, TaskInfo task) Executes a task.
static Optional<Path>	TaskExecutors.findApplicationFile(TaskExecutionContext context, String location) Returns a file in the current batch application package.
static Optional<Path>	TaskExecutors.findApplicationWorkflowDefinitionFile(TaskExecutionContext context) Returns an application workflow definition file.
static Set<Path>	TaskExecutors.findAttachedLibraries(TaskExecutionContext context) Returns the attached library files.
static Optional<Path>	TaskExecutors.findJobflowLibrary(TaskExecutionContext context) Returns the jobflow library file.
boolean	TaskExecutor.isSupported(TaskExecutionContext context, TaskInfo task) Returns whether this executor supports executing the target task.
static String	TaskExecutors.resolveCommandToken(TaskExecutionContext context, CommandToken token) Resolves a CommandToken for the current execution context.
static List<String>	TaskExecutors.resolveCommandTokens(TaskExecutionContext context, List<? extends CommandToken> tokens) Resolves a list of CommandToken for the current execution context.
static String	TaskExecutors.resolvePath(TaskExecutionContext context, String path) Resolves a path string using the current context.
static void	TaskExecutors.withLibraries(TaskExecutionContext context, List<? extends Path> libraries, TaskExecutors.IoConsumer<? super ClassLoader> action) Loads the libraries and performs the given action.
static void	TaskExecutors.withLibraries(TaskExecutionContext context, TaskExecutors.IoConsumer<? super ClassLoader> action) Loads the current batch libraries and performs the given action.

Uses of TaskExecutionContext in com.asakusafw.workflow.executor.basic

Classes in com.asakusafw.workflow.executor.basic that implement TaskExecutionContext

Modifier and Type	Class and Description
class	BasicTaskExecutionContext A basic implementation of TaskExecutionContext.

Methods in com.asakusafw.workflow.executor.basic with parameters of type TaskExecutionContext

Modifier and Type	Method and Description
protected void	BasicDeleteTaskExecutor.deleteOnHadoopFileSystem(TaskExecutionContext context, String path) Delete files on Hadoop file system.
protected void	BasicDeleteTaskExecutor.deleteOnLocalFileSystem(TaskExecutionContext context, String path) Delete files on local file system.
static void	BasicCommandTaskExecutor.execute(TaskExecutionContext context, CommandLauncher launcher, Path command, List<String> arguments) Executes a command.
void	BasicJobflowExecutor.execute(TaskExecutionContext context, JobflowInfo jobflow)
static void	BasicCommandTaskExecutor.execute(TaskExecutionContext context, Path command, List<String> arguments) Executes a command.
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)

Constructor parameters in com.asakusafw.workflow.executor.basic with type arguments of type TaskExecutionContext

Constructor and Description
BasicCommandTaskExecutor(Function<? super TaskExecutionContext,? extends CommandLauncher> launchers) Creates a new instance.

Uses of TaskExecutionContext in com.asakusafw.workflow.hadoop

Methods in com.asakusafw.workflow.hadoop with parameters of type TaskExecutionContext

Modifier and Type	Method and Description
protected void	BridgeDeleteTaskExecutor.deleteOnHadoopFileSystem(TaskExecutionContext context, String path)
void	BridgeHadoopTaskExecutor.execute(TaskExecutionContext context, TaskInfo task)
boolean	BridgeDeleteTaskExecutor.isSupported(TaskExecutionContext context, TaskInfo task)
boolean	BridgeHadoopTaskExecutor.isSupported(TaskExecutionContext context, TaskInfo task)

Constructor parameters in com.asakusafw.workflow.hadoop with type arguments of type TaskExecutionContext

Constructor and Description
BridgeDeleteTaskExecutor(Function<? super TaskExecutionContext,? extends CommandLauncher> launchers) Creates a new instance.
BridgeHadoopTaskExecutor(Function<? super TaskExecutionContext,? extends CommandLauncher> launchers) Creates a new instance.