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.multidispatch |
YAESS Script Handler Dispatcher.
|
com.asakusafw.yaess.paralleljob |
Simple Parallel Job Scheduler Plug-in for YAESS.
|
Modifier and Type | Class and Description |
---|---|
class |
LoggingExecutionMonitor
An implementation of
ExecutionMonitor using default logger. |
Modifier and Type | Method and Description |
---|---|
void |
ProcessHadoopScriptHandler.cleanUp(ExecutionMonitor monitor,
ExecutionContext context) |
void |
ProcessCommandScriptHandler.cleanUp(ExecutionMonitor monitor,
ExecutionContext context) |
void |
ProcessCommandScriptHandler.execute(ExecutionMonitor monitor,
ExecutionContext context,
CommandScript script) |
void |
ProcessHadoopScriptHandler.execute(ExecutionMonitor monitor,
ExecutionContext context,
HadoopScript script) |
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) |
Constructor and Description |
---|
Executing(ExecutionMonitor monitor,
ExecutionContext context,
Job job,
BlockingQueue<JobExecutor.Executing> doneQueue)
Creates a new instance.
|
Modifier and Type | Class and Description |
---|---|
class |
JobMonitor
Receives job's progress.
|
class |
PhaseMonitor
Receives phase execution's progress.
|
Modifier and Type | Field and Description |
---|---|
static ExecutionMonitor |
ExecutionMonitor.NULL
An empty implementation.
|
Modifier and Type | Method and Description |
---|---|
ExecutionMonitor |
PhaseMonitor.createJobMonitor(String jobId,
double childTaskSize)
Creates a new child task monitor with the specified task size.
|
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.
|
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.
|
void |
Job.launch(ExecutionMonitor monitor,
ExecutionContext context)
Executes this job.
|
void |
ExecutionScriptHandlerBase.setUp(ExecutionMonitor monitor,
ExecutionContext context)
Setup the target environment.
|
void |
ExecutionScriptHandler.setUp(ExecutionMonitor monitor,
ExecutionContext context)
Setup the target environment.
|
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) |
Modifier and Type | Class and Description |
---|---|
class |
FlowLogger
An implementation of
PhaseMonitor to save log for each jobflow. |
Modifier and Type | Method and Description |
---|---|
void |
QueueHadoopScriptHandler.cleanUp(ExecutionMonitor monitor,
ExecutionContext context) |
void |
QueueHadoopScriptHandler.execute(ExecutionMonitor monitor,
ExecutionContext context,
HadoopScript script) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionScriptHandlerDispatcher.cleanUp(ExecutionMonitor monitor,
ExecutionContext context) |
void |
ExecutionScriptHandlerDispatcher.execute(ExecutionMonitor monitor,
ExecutionContext context,
T script) |
void |
ExecutionScriptHandlerDispatcher.setUp(ExecutionMonitor monitor,
ExecutionContext context) |
Modifier and Type | Method and Description |
---|---|
JobExecutor.Executing |
ParallelJobExecutor.submit(ExecutionMonitor monitor,
ExecutionContext context,
Job job,
BlockingQueue<JobExecutor.Executing> doneQueue) |
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.