Uses of Class
com.asakusafw.yaess.core.ExecutionContext

Packages that use ExecutionContext

Package	Description
com.asakusafw.yaess.basic	Basic modules for YAESS.
com.asakusafw.yaess.core	Core models/interfaces for YAESS.
com.asakusafw.yaess.core.task	Facade tasks for YAESS.
com.asakusafw.yaess.flowlog	Generate logs for individual jobflow executions.
com.asakusafw.yaess.jobqueue	YAESS Hadoop Script Handlers for Job Queue.
com.asakusafw.yaess.jsch	YAESS Script Handlers via JSch.
com.asakusafw.yaess.multidispatch	YAESS Script Handler Dispatcher.
com.asakusafw.yaess.paralleljob	Simple Parallel Job Scheduler Plug-in for YAESS.

Uses of ExecutionContext in com.asakusafw.yaess.basic

Methods in com.asakusafw.yaess.basic with parameters of type ExecutionContext

Modifier and Type	Method and Description
void	ProcessHadoopScriptHandler.cleanUp(ExecutionMonitor monitor, ExecutionContext context)
void	ProcessCommandScriptHandler.cleanUp(ExecutionMonitor monitor, ExecutionContext context)
default int	ProcessExecutor.execute(ExecutionContext context, List<String> commandLineTokens, Map<String,String> environmentVariables) Executes a process.
int	ProcessExecutor.execute(ExecutionContext context, List<String> commandLineTokens, Map<String,String> environmentVariables, Map<String,Blob> extensions, OutputStream output) Executes a process.
default int	ProcessExecutor.execute(ExecutionContext context, List<String> commandLineTokens, Map<String,String> environmentVariables, OutputStream output) Executes a process.
void	ProcessCommandScriptHandler.execute(ExecutionMonitor monitor, ExecutionContext context, CommandScript script)
void	ProcessHadoopScriptHandler.execute(ExecutionMonitor monitor, ExecutionContext context, HadoopScript script)
void	AbstractJobScheduler.execute(PhaseMonitor monitor, ExecutionContext context, List<? extends Job> jobs, JobScheduler.ErrorHandler errorHandler)
static Map<String,Blob>	BlobUtil.getExtensions(ExecutionContext context, ExecutionScript script) Builds extensions for the script.
PhaseMonitor	BasicMonitorProvider.newInstance(ExecutionContext context)
void	ProcessCommandScriptHandler.setUp(ExecutionMonitor monitor, ExecutionContext context)
JobExecutor.Executing	JobExecutor.submit(ExecutionMonitor monitor, ExecutionContext context, Job job, BlockingQueue<JobExecutor.Executing> doneQueue) Submits a job.
JobExecutor.Executing	ThreadedJobExecutor.submit(ExecutionMonitor monitor, ExecutionContext context, Job job, BlockingQueue<JobExecutor.Executing> doneQueue)

Constructors in com.asakusafw.yaess.basic with parameters of type ExecutionContext

Constructor and Description
Executing(ExecutionMonitor monitor, ExecutionContext context, Job job, BlockingQueue<JobExecutor.Executing> doneQueue) Creates a new instance.
LoggingExecutionMonitor(ExecutionContext context, double stepUnit) Creates a new instance.

Uses of ExecutionContext in com.asakusafw.yaess.core

Methods in com.asakusafw.yaess.core with parameters of type ExecutionContext

Modifier and Type	Method and Description
void	ExecutionScriptHandlerBase.cleanUp(ExecutionMonitor monitor, ExecutionContext context) Cleanup the target environment.
void	ExecutionScriptHandler.cleanUp(ExecutionMonitor monitor, ExecutionContext context) Cleanup the target environment.
static String	Job.computeTrackingId(ExecutionContext context) Computes the tracking ID for script-less job.
static String	Job.computeTrackingId(ExecutionContext context, ExecutionScript script) Computes the tracking ID.
protected abstract void	Job.execute(ExecutionMonitor monitor, ExecutionContext context) Executes this job.
void	ExecutionScriptHandler.execute(ExecutionMonitor monitor, ExecutionContext context, T script) Executes the specified script.
abstract void	JobScheduler.execute(PhaseMonitor monitor, ExecutionContext context, List<? extends Job> jobs, JobScheduler.ErrorHandler errorHandler) Executes a series of jobs.
Map<String,String>	ExecutionScriptHandlerBase.getEnvironmentVariables(ExecutionContext context, ExecutionScript script) Returns desired environment variables to execute scripts using this handler.
Map<String,String>	ExecutionScriptHandler.getEnvironmentVariables(ExecutionContext context, ExecutionScript script) Returns desired environment variables to execute scripts using this handler.
Map<String,String>	ExecutionScriptHandlerBase.getProperties(ExecutionContext context, ExecutionScript script) Returns desired system/hadoop properties to execute scripts using this handler.
Map<String,String>	ExecutionScriptHandler.getProperties(ExecutionContext context, ExecutionScript script) Returns desired system/hadoop properties to execute scripts using this handler.
abstract String	Job.getResourceId(ExecutionContext context) Returns the resource ID which this job requires in execution.
String	ExecutionScriptHandlerBase.getResourceId(ExecutionContext context, ExecutionScript script) Returns the ID of a resource which is used for executing this handler.
String	ExecutionScriptHandler.getResourceId(ExecutionContext context, ExecutionScript script) Returns the ID of a resource which is used for executing this handler.
String	Job.getTrackingId(ExecutionContext context) Returns the tracking ID of this job.
abstract boolean	JobScheduler.ErrorHandler.handle(ExecutionContext context, IOException exception) Invoked when failed to execute the job in JobScheduler.execute(PhaseMonitor, ExecutionContext, List, ErrorHandler).
void	Job.launch(ExecutionMonitor monitor, ExecutionContext context) Executes this job.
abstract PhaseMonitor	ExecutionMonitorProvider.newInstance(ExecutionContext context) Creates a new PhaseMonitor.
CommandScript	CommandScript.resolve(ExecutionContext context, ExecutionScriptHandler<?> handler)
HadoopScript	HadoopScript.resolve(ExecutionContext context, ExecutionScriptHandler<?> handler)
ExecutionScript	ExecutionScript.resolve(ExecutionContext context, ExecutionScriptHandler<?> handler) Resolves placeholders defined in this script.
void	ExecutionScriptHandlerBase.setUp(ExecutionMonitor monitor, ExecutionContext context) Setup the target environment.
void	ExecutionScriptHandler.setUp(ExecutionMonitor monitor, ExecutionContext context) Setup the target environment.
protected void	ExecutionScriptHandlerBase.voidCleanUp(ExecutionContext context) Performs as ExecutionScriptHandlerBase.cleanUp(ExecutionMonitor, ExecutionContext) that does nothing.
protected void	ExecutionScriptHandlerBase.voidSetUp(ExecutionContext context) Performs as ExecutionScriptHandlerBase.setUp(ExecutionMonitor, ExecutionContext) that does nothing.

Constructors in com.asakusafw.yaess.core with parameters of type ExecutionContext

Constructor and Description
PlaceholderResolver(ExecutionScript script, ExecutionContext context, ExecutionScriptHandler<?> handler) Creates a new instance.

Uses of ExecutionContext in com.asakusafw.yaess.core.task

Methods in com.asakusafw.yaess.core.task with parameters of type ExecutionContext

Modifier and Type	Method and Description
void	ScriptJob.execute(ExecutionMonitor monitor, ExecutionContext context)
void	CleanupJob.execute(ExecutionMonitor monitor, ExecutionContext context)
void	SetupJob.execute(ExecutionMonitor monitor, ExecutionContext context)
void	ExecutionTask.executePhase(ExecutionContext context) Executes a target phase.
String	ScriptJob.getResourceId(ExecutionContext context)
String	HandlerLifecycleJob.getResourceId(ExecutionContext context)
String	ScriptJob.getTrackingId(ExecutionContext context)
String	HandlerLifecycleJob.getTrackingId(ExecutionContext context)

Uses of ExecutionContext in com.asakusafw.yaess.flowlog

Methods in com.asakusafw.yaess.flowlog with parameters of type ExecutionContext

Modifier and Type	Method and Description
File	FlowLoggerProfile.getEscapeFile(ExecutionContext context) Returns abstract path for the escaped log file.
File	FlowLoggerProfile.getLogFile(ExecutionContext context) Returns abstract path for the target log file.
PhaseMonitor	FlowLoggerProvider.newInstance(ExecutionContext context)

Constructors in com.asakusafw.yaess.flowlog with parameters of type ExecutionContext

Constructor and Description
FlowLogger(ExecutionContext context, FlowLoggerProfile profile) Creates a new instance.

Uses of ExecutionContext in com.asakusafw.yaess.jobqueue

Methods in com.asakusafw.yaess.jobqueue with parameters of type ExecutionContext

Modifier and Type	Method and Description
void	QueueHadoopScriptHandler.cleanUp(ExecutionMonitor monitor, ExecutionContext context)
void	QueueHadoopScriptHandler.execute(ExecutionMonitor monitor, ExecutionContext context, HadoopScript script)

Uses of ExecutionContext in com.asakusafw.yaess.jsch

Methods in com.asakusafw.yaess.jsch with parameters of type ExecutionContext

Modifier and Type	Method and Description
int	JschProcessExecutor.execute(ExecutionContext context, List<String> commandLineTokens, Map<String,String> environmentVariables, Map<String,Blob> extensions, OutputStream output)

Uses of ExecutionContext in com.asakusafw.yaess.multidispatch

Methods in com.asakusafw.yaess.multidispatch with parameters of type ExecutionContext

Modifier and Type	Method and Description
void	ExecutionScriptHandlerDispatcher.cleanUp(ExecutionMonitor monitor, ExecutionContext context)
void	ExecutionScriptHandlerDispatcher.execute(ExecutionMonitor monitor, ExecutionContext context, T script)
Map<String,String>	ExecutionScriptHandlerDispatcher.getEnvironmentVariables(ExecutionContext context, ExecutionScript script)
Map<String,String>	ExecutionScriptHandlerDispatcher.getProperties(ExecutionContext context, ExecutionScript script)
String	ExecutionScriptHandlerDispatcher.getResourceId(ExecutionContext context, ExecutionScript script)
void	ExecutionScriptHandlerDispatcher.setUp(ExecutionMonitor monitor, ExecutionContext context)

Uses of ExecutionContext in com.asakusafw.yaess.paralleljob

Methods in com.asakusafw.yaess.paralleljob with parameters of type ExecutionContext

Modifier and Type	Method and Description
JobExecutor.Executing	ParallelJobExecutor.submit(ExecutionMonitor monitor, ExecutionContext context, Job job, BlockingQueue<JobExecutor.Executing> doneQueue)