com.asakusafw.yaess.core.task

Class ExecutionTask

java.lang.Object

com.asakusafw.yaess.core.task.ExecutionTask

public class ExecutionTask
extends Object

Task to execute target batch, flow, or phase.

Since:

0.2.3

Version:

0.8.0

Method Summary

Modifier and Type	Method and Description
void	executeBatch(String batchId) Executes a target flow.
void	executeFlow(String batchId, String flowId, String executionId) Executes a target flow.
void	executePhase(ExecutionContext context) Executes a target phase.
void	executePhase(String batchId, String flowId, String executionId, ExecutionPhase phase) Executes a target phase.
static ExecutionTask	load(YaessProfile profile, Properties script, Map<String,String> batchArguments) Loads profile and create a new ExecutionTask.
static ExecutionTask	load(YaessProfile profile, Properties script, Map<String,String> batchArguments, Map<String,String> yaessArguments) Loads profile and create a new ExecutionTask.
static ExecutionTask	load(YaessProfile profile, Properties script, Map<String,String> batchArguments, Map<String,String> yaessArguments, Map<String,Blob> extensions) Loads profile and create a new ExecutionTask.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

load

public static ExecutionTask load(YaessProfile profile,
                                 Properties script,
                                 Map<String,String> batchArguments)
                          throws InterruptedException,
                                 IOException

Loads profile and create a new ExecutionTask.

Parameters:

profile - target profile

script - target script

batchArguments - current batch arguments

Returns:

the created task

Throws:

InterruptedException - if interrupted while configuring services

IOException - if failed to configure services

IllegalArgumentException - if some parameters were null

load

public static ExecutionTask load(YaessProfile profile,
                                 Properties script,
                                 Map<String,String> batchArguments,
                                 Map<String,String> yaessArguments)
                          throws InterruptedException,
                                 IOException

Loads profile and create a new ExecutionTask.

Parameters:

profile - target profile

script - target script

batchArguments - current batch arguments

yaessArguments - current control arguments

Returns:

the created task

Throws:

InterruptedException - if interrupted while configuring services

IOException - if failed to configure services

IllegalArgumentException - if some parameters were null

Since:

0.2.6

load

public static ExecutionTask load(YaessProfile profile,
                                 Properties script,
                                 Map<String,String> batchArguments,
                                 Map<String,String> yaessArguments,
                                 Map<String,Blob> extensions)
                          throws InterruptedException,
                                 IOException

Loads profile and create a new ExecutionTask.

Parameters:

profile - target profile

script - target script

batchArguments - current batch arguments

yaessArguments - current control arguments

extensions - extension BLOBs

Returns:

the created task

Throws:

InterruptedException - if interrupted while configuring services

IOException - if failed to configure services

IllegalArgumentException - if some parameters were null

Since:

0.8.0

executeBatch

public void executeBatch(String batchId)
                  throws InterruptedException,
                         IOException

Executes a target flow. If execution is failed except on setup, finalize, or cleanup, then the finalize phase will be executed for recovery before the target flow execution is aborted. Execution ID for each flow will automatically generated.

Parameters:

batchId - target batch ID

Throws:

InterruptedException - if interrupted during this execution

IOException - if failed to execute target batch

IllegalArgumentException - if some parameters were null

executeFlow

public void executeFlow(String batchId,
                        String flowId,
                        String executionId)
                 throws InterruptedException,
                        IOException

Executes a target flow. If execution is failed except on setup, finalize, or cleanup, then the finalize phase will be executed for recovery before execution is aborted.

Parameters:

batchId - target batch ID

flowId - target flow ID

executionId - target execution ID

Throws:

InterruptedException - if interrupted during this execution

IOException - if failed to execute target flow

IllegalArgumentException - if some parameters were null

executePhase

public void executePhase(String batchId,
                         String flowId,
                         String executionId,
                         ExecutionPhase phase)
                  throws InterruptedException,
                         IOException

Executes a target phase.

Parameters:

batchId - target batch ID

flowId - target flow ID

executionId - target execution ID

phase - target phase

Throws:

InterruptedException - if interrupted during this execution

IOException - if failed to execute target phase

IllegalArgumentException - if some parameters were null

executePhase

public void executePhase(ExecutionContext context)
                  throws InterruptedException,
                         IOException

Executes a target phase.

Parameters:

context - the current context

Throws:

InterruptedException - if interrupted during this execution

IOException - if failed to execute target phase

IllegalArgumentException - if some parameters were null

Since:

0.2.5