public class JobFlowTester extends TesterBase
JobFlow jobflow classes.| Modifier and Type | Field and Description |
|---|---|
protected List<JobFlowDriverInput<?>> |
inputs
The flow inputs.
|
protected List<JobFlowDriverOutput<?>> |
outputs
The flow outputs.
|
driverContext| Constructor and Description |
|---|
JobFlowTester(Class<?> callerClass)
Creates a new instance.
|
| Modifier and Type | Method and Description |
|---|---|
<T> JobFlowDriverInput<T> |
input(String name,
Class<T> modelType)
Starts configuring the target flow input.
|
<T> JobFlowDriverOutput<T> |
output(String name,
Class<T> modelType)
Starts configuring the target flow output.
|
void |
runTest(Class<? extends FlowDescription> description)
Executes a jobflow and then verifies the execution result.
|
getExternalResources, loader, loader, loader, loader, loader, loader, putExternalResourceaddInputTrace, addInputTrace, addOutputTrace, addOutputTrace, configure, getCallerClass, getTestTools, setBatchArg, setCompilerWorkingDirectory, setDebug, setExtraCompilerOption, setFrameworkHomePath, setJobExecutorFactory, setLibrariesPath, setOptimize, skipCleanInput, skipCleanOutput, skipPrepareInput, skipPrepareOutput, skipRunJobflow, skipValidateCondition, skipVerifytoDataModelSinkFactory, toDataModelSourceFactory, toDataModelSourceFactory, toDataModelSourceFactory, toDataModelSourceFactory, toDataModelSourceFactory, toDataModelSourceFilter, toOutputUri, toUri, toVerifierFactoryprotected final List<JobFlowDriverInput<?>> inputs
protected final List<JobFlowDriverOutput<?>> outputs
public JobFlowTester(Class<?> callerClass)
callerClass - the caller class (usually it is a test class)public <T> JobFlowDriverInput<T> input(String name, Class<T> modelType)
T - the data model typename - the target input name (specified in @Import(name=...))modelType - the data model typepublic <T> JobFlowDriverOutput<T> output(String name, Class<T> modelType)
T - the data model typename - the target output name (specified in @Export(name=...))modelType - the data model typepublic void runTest(Class<? extends FlowDescription> description)
description - the target jobflow classIllegalStateException - if error was occurred while building jobflow class or initializing this testerAssertionError - if verification was failedCopyright © 2011–2018 Asakusa Framework Team. All rights reserved.