com.asakusafw.testdriver

Class FlowDriverInput<T,S extends FlowDriverInput<T,S>>

java.lang.Object

com.asakusafw.testdriver.DriverElementBase

com.asakusafw.testdriver.DriverInputBase<T>

com.asakusafw.testdriver.FlowDriverInput<T,S>

Type Parameters:

T - the input data model type

S - the implementation class type

Direct Known Subclasses:

FlowPartDriverInput, JobFlowDriverInput

public abstract class FlowDriverInput<T,S extends FlowDriverInput<T,S>>
extends DriverInputBase<T>

An abstract super class which represents an input port of data flow on testing. Clients should not inherit this class directly.

Since:

0.6.0

Version:

0.9.1

Constructor Summary

Constructors

Constructor and Description
FlowDriverInput(Class<?> callerClass, TestDataToolProvider testTools, String name, Class<T> modelType) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
protected abstract S	getThis() Returns this object.
S	prepare(Class<? extends DataFormat<? super T>> formatClass, File sourceFile) Sets the test data set for this input.
S	prepare(Class<? extends DataFormat<? super T>> formatClass, File sourceFile, Consumer<? super T> transformer) Sets the test data set for this input.
S	prepare(Class<? extends DataFormat<? super T>> formatClass, String sourcePath) Sets the test data set for this input.
S	prepare(Class<? extends DataFormat<? super T>> formatClass, String sourcePath, Consumer<? super T> transformer) Sets the test data set for this input.
S	prepare(DataModelSourceFactory factory) Sets the test data set for this input.
S	prepare(DataModelSourceFactory factory, Consumer<? super T> transformer) Sets the test data set for this input.
S	prepare(Iterable<? extends T> objects) Sets the test data set for this input.
S	prepare(Provider<? extends Source<? extends T>> provider) Sets the test data set for this input.
S	prepare(String sourcePath) Sets the test data set for this input.
S	prepare(String sourcePath, Consumer<? super T> transformer) Sets the test data set for this input.
S	with(Consumer<? super S> configurator) Configures this object.

Methods inherited from class com.asakusafw.testdriver.DriverInputBase

getCallerClass, getDataModelDefinition, getModelType, getName, getSource, getTestTools, setSource, toDataModelSourceFactory, toDataModelSourceFilter

Methods inherited from class com.asakusafw.testdriver.DriverElementBase

toDataModelSinkFactory, toDataModelSourceFactory, toDataModelSourceFactory, toDataModelSourceFactory, toDataModelSourceFactory, toDataModelSourceFactory, toDataModelSourceFilter, toOutputUri, toUri, toVerifierFactory

Methods inherited from class java.lang.Object

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

Constructor Detail

FlowDriverInput

public FlowDriverInput(Class<?> callerClass,
                       TestDataToolProvider testTools,
                       String name,
                       Class<T> modelType)

Creates a new instance.

Parameters:

callerClass - the current context class

testTools - the test data tools

name - the original input name

modelType - the data model type

Since:

0.6.0

Method Detail

getThis

protected abstract S getThis()

Returns this object.

Returns:

this

Since:

0.6.0

prepare

public S prepare(String sourcePath)

Sets the test data set for this input.

Parameters:

sourcePath - the path to test data set

Returns:

this

Throws:

IllegalArgumentException - if the source was not found on the path

Since:

0.2.0

prepare

public S prepare(String sourcePath,
                 Consumer<? super T> transformer)

Sets the test data set for this input.

Parameters:

sourcePath - the path to test data set

transformer - the input source transformer

Returns:

this

Throws:

IllegalArgumentException - if the source was not found on the path

Since:

0.10.2

prepare

public S prepare(DataModelSourceFactory factory)

Sets the test data set for this input.

Parameters:

factory - factory which provides test data set

Returns:

this

Since:

0.6.0

prepare

public S prepare(DataModelSourceFactory factory,
                 Consumer<? super T> transformer)

Sets the test data set for this input.

Parameters:

factory - factory which provides test data set

transformer - the input source transformer

Returns:

this

Since:

0.10.2

prepare

public S prepare(Iterable<? extends T> objects)

Sets the test data set for this input.

Parameters:

objects - the test data objects

Returns:

this

Since:

0.6.0

prepare

public S prepare(Provider<? extends Source<? extends T>> provider)

Sets the test data set for this input.

Parameters:

provider - the test data set provider

Returns:

this

Since:

0.6.0

prepare

public S prepare(Class<? extends DataFormat<? super T>> formatClass,
                 String sourcePath)

Sets the test data set for this input. Note that, the original source path may be changed if tracking source file name. To keep the source file path information, please use prepare(Class, File) instead.

Parameters:

formatClass - the data format class

sourcePath - the input file path on the class path

Returns:

this

Throws:

IllegalArgumentException - if the source is not valid for the given data format

Since:

0.9.1

prepare

public S prepare(Class<? extends DataFormat<? super T>> formatClass,
                 String sourcePath,
                 Consumer<? super T> transformer)

Sets the test data set for this input. Note that, the original source path may be changed if tracking source file name. To keep the source file path information, please use prepare(Class, File) instead.

Parameters:

formatClass - the data format class

sourcePath - the input file path on the class path

transformer - the input source transformer

Returns:

this

Throws:

IllegalArgumentException - if the source is not valid for the given data format

Since:

0.10.2

prepare

public S prepare(Class<? extends DataFormat<? super T>> formatClass,
                 File sourceFile)

Sets the test data set for this input.

Parameters:

formatClass - the data format class

sourceFile - the input file

Returns:

this

Throws:

IllegalArgumentException - if the source is not valid for the given data format

Since:

0.9.1

prepare

public S prepare(Class<? extends DataFormat<? super T>> formatClass,
                 File sourceFile,
                 Consumer<? super T> transformer)

Sets the test data set for this input.

Parameters:

formatClass - the data format class

sourceFile - the input file

transformer - the input source transformer

Returns:

this

Throws:

IllegalArgumentException - if the source is not valid for the given data format

Since:

0.10.2

with

public S with(Consumer<? super S> configurator)

Configures this object.

Parameters:

configurator - the configurator

Returns:

this

Since:

0.10.2