Class Source<I>

java.lang.Object

ca.mcscert.jpipe.compiler.model.Source<I>

Type Parameters:

I - type produced for the downstream transformation.

Direct Known Subclasses:

FileSource

public abstract class Source<I>
extends Object

First step of a compilation chain: reads an input file and produces the initial value fed to the first Transformation.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	Source.Provider<I>	Functional interface for the of(Source.Provider) factory.

Constructor Summary

Constructors

Constructor	Description
Source()

Method Summary

Modifier and Type	Method	Description
final <R> ChainBuilder<I,R>	andThen(Transformation<I,R> next)	DSL entry-point: combine this source with the first transformation to start building a compilation chain.
static <I> Source<I>	of(Source.Provider<I> provider)	Create a Source from a lambda or method reference.
abstract I	provideFrom(String sourceName)	Read sourceName and produce the initial pipeline value.

Methods inherited from class Object

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

Constructor Details

Source

public Source()

Method Details

of

public static <I> Source<I> of(Source.Provider<I> provider)

Create a Source from a lambda or method reference.

provideFrom

public abstract I provideFrom(String sourceName)
                       throws IOException

Read sourceName and produce the initial pipeline value.

Parameters:

sourceName - path to the input file.

Returns:

an instance of I.

Throws:

IOException - if the file cannot be read.

andThen

public final <R> ChainBuilder<I,R> andThen(Transformation<I,R> next)

DSL entry-point: combine this source with the first transformation to start building a compilation chain.

Type Parameters:

R - output type of next.

Parameters:

next - the transformation to apply to this source's output.

Returns:

a ChainBuilder accumulating further steps.