com.asakusafw.workflow.executor.basic

Class BasicBatchExecutor

java.lang.Object

com.asakusafw.workflow.executor.basic.BasicBatchExecutor

All Implemented Interfaces:

BatchExecutor

public class BasicBatchExecutor
extends Object
implements BatchExecutor

A basic implementation of BatchExecutor.

Since:

0.10.0

Constructor Summary

Constructors

Constructor and Description
BasicBatchExecutor(JobflowExecutor jobflowExecutor) Creates a new instance.
BasicBatchExecutor(JobflowExecutor jobflowExecutor, Function<JobflowInfo,String> executionIds) Creates a new instance.
BasicBatchExecutor(JobflowExecutor jobflowExecutor, Supplier<String> executionIds) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	execute(ExecutionContext context, BatchInfo batch, Map<String,String> arguments) Executes the given batch.
BasicBatchExecutor	withValidateParameters(boolean enable) Sets whether or not validates batch arguments.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.asakusafw.workflow.executor.BatchExecutor

execute

Constructor Detail

BasicBatchExecutor

public BasicBatchExecutor(JobflowExecutor jobflowExecutor,
                          Function<JobflowInfo,String> executionIds)

Creates a new instance.

Parameters:

jobflowExecutor - the jobflow executor

executionIds - the execution ID generator

BasicBatchExecutor

public BasicBatchExecutor(JobflowExecutor jobflowExecutor,
                          Supplier<String> executionIds)

Creates a new instance.

Parameters:

jobflowExecutor - the jobflow executor

executionIds - the execution ID generator

BasicBatchExecutor

public BasicBatchExecutor(JobflowExecutor jobflowExecutor)

Creates a new instance.

Parameters:

jobflowExecutor - the jobflow executor

Method Detail

withValidateParameters

public BasicBatchExecutor withValidateParameters(boolean enable)

Sets whether or not validates batch arguments.

Parameters:

enable - true to enable batch arguments, otherwise false

Returns:

this

execute

public void execute(ExecutionContext context,
                    BatchInfo batch,
                    Map<String,String> arguments)
             throws IOException,
                    InterruptedException

Description copied from interface: BatchExecutor

Executes the given batch.

Specified by:

execute in interface BatchExecutor

Parameters:

context - the current context

batch - the target batch

arguments - the batch arguments

Throws:

IOException - if failed to create job processes

InterruptedException - if interrupted while running tasks