Uses of Interface
com.asakusafw.utils.io.Source

Packages that use Source

Package	Description
com.asakusafw.runtime.mapreduce.simple	Simplified MapReduce engine.
com.asakusafw.testdriver	Test driver classes.
com.asakusafw.testdriver.core	Core classes of test moderator.
com.asakusafw.testdriver.directio.api	Tester APIs of Direct I/O.
com.asakusafw.utils.io	Simple Object I/O APIs.
com.asakusafw.utils.io.csv	CSV format I/O utilities.

Uses of Source in com.asakusafw.runtime.mapreduce.simple

Methods in com.asakusafw.runtime.mapreduce.simple that return Source

Modifier and Type	Method and Description
Source<KeyValueSlice>	KeyValueSorter.sort() Sort previously added key-value pairs.

Uses of Source in com.asakusafw.testdriver

Method parameters in com.asakusafw.testdriver with type arguments of type Source

Modifier and Type	Method and Description
<T> DataLoader<T>	OperatorTestEnvironment.loader(Class<T> dataType, Provider<? extends Source<? extends T>> provider) Returns a new data loader.
<T> DataLoader<T>	TesterBase.loader(Class<T> dataType, Provider<? extends Source<? extends T>> provider) Returns a new data loader.
S	FlowDriverOutput.prepare(Provider<? extends Source<? extends T>> provider) Sets the initial data set for this output.
S	FlowDriverInput.prepare(Provider<? extends Source<? extends T>> provider) Sets the test data set for this input.
protected <T> DataModelSourceFactory	DriverElementBase.toDataModelSourceFactory(Provider<? extends Source<? extends T>> sourceProvider) Converts an data model object collection into DataModelSourceFactory which provides data models.
S	FlowDriverOutput.verify(Provider<? extends Source<? extends T>> expectedProvider, ModelVerifier<? super T> modelVerifier) Enables to verify the results of this output.
S	FlowDriverOutput.verify(Provider<? extends Source<? extends T>> expectedProvider, String verifyRulePath) Enables to verify the results of this output.
S	FlowDriverOutput.verify(Provider<? extends Source<? extends T>> expectedProvider, String verifyRulePath, ModelTester<? super T> tester) Enables to verify the results of this output.

Uses of Source in com.asakusafw.testdriver.core

Constructors in com.asakusafw.testdriver.core with parameters of type Source

Constructor and Description
SourceDataModelSource(DataModelDefinition<T> definition, Source<? extends T> source) Creates a new instance.

Constructor parameters in com.asakusafw.testdriver.core with type arguments of type Source

Constructor and Description
SourceDataModelSourceFactory(Class<T> sourceType, Provider<? extends Source<? extends T>> sourceProvider) Creates a new instance.
SourceDataModelSourceFactory(Provider<? extends Source<?>> sourceProvider) Creates a new instance.

Uses of Source in com.asakusafw.testdriver.directio.api

Method parameters in com.asakusafw.testdriver.directio.api with type arguments of type Source

Modifier and Type	Method and Description
void	DirectIoTester.DirectIoResource.prepare(Provider<? extends Source<?>> provider) Sets a data source provider for this external resource.

Uses of Source in com.asakusafw.utils.io

Classes in com.asakusafw.utils.io that implement Source

Modifier and Type	Class and Description
static class	DefaultSerialization.ObjectSource<T> An ObjectInput adapter implementation of Source.

Methods in com.asakusafw.utils.io that return Source

Modifier and Type	Method and Description
static <T> Source<T>	Sources.concat(List<? extends Source<? extends T>> sources) Concatenates a list of sources.
Source<T>	DefaultSerialization.createSource(InputStream stream)
Source<T>	Serialization.createSource(InputStream stream) Creates a new Source using the InputStream.
static <T> Source<T>	Sources.empty() Returns an empty Source.
static <T> Source<T>	Sources.merge(List<? extends Source<? extends T>> sortedSources, Comparator<? super T> comparator) Merges the sorted sources.
static <T> Source<T>	Sources.wrap(Iterator<? extends T> iterator) Wraps Iterator object.
static <T> Source<T>	Sources.wrap(T... values) Returns a Source for the array.

Method parameters in com.asakusafw.utils.io with type arguments of type Source

Modifier and Type	Method and Description
static <T> Source<T>	Sources.concat(List<? extends Source<? extends T>> sources) Concatenates a list of sources.
static <T> Source<T>	Sources.merge(List<? extends Source<? extends T>> sortedSources, Comparator<? super T> comparator) Merges the sorted sources.

Uses of Source in com.asakusafw.utils.io.csv

Classes in com.asakusafw.utils.io.csv that implement Source

Modifier and Type	Class and Description
class	CsvReader A simple implementation of CSV reader.