Uses of Interface
com.asakusafw.vocabulary.flow.Source

Packages that use Source

Package	Description
com.asakusafw.testdriver	Test driver classes.
com.asakusafw.vocabulary.flow	Flow DSL vocabulary annotations/classes about data flow representations.
com.asakusafw.vocabulary.flow.builder	Flow connection APIs (for internal use only).
com.asakusafw.vocabulary.flow.graph	Internal graphical representation of Flow DSL.
com.asakusafw.vocabulary.flow.testing	Classes for Flow DSL testing.
com.asakusafw.vocabulary.flow.util	Provides built-in Flow DSL vocabularies.

Uses of Source in com.asakusafw.testdriver

Classes in com.asakusafw.testdriver that implement Source

Modifier and Type	Class and Description
class	FlowPartDriverInput<T> A flow input driver for testing flow-parts.

Methods in com.asakusafw.testdriver with parameters of type Source

Modifier and Type	Method and Description
void	FlowPartDriverOutput.add(Source<T> upstream)

Uses of Source in com.asakusafw.vocabulary.flow

Subinterfaces of Source in com.asakusafw.vocabulary.flow

Modifier and Type	Interface and Description
interface	In<T> Represents a flow input.

Methods in com.asakusafw.vocabulary.flow with parameters of type Source

Modifier and Type	Method and Description
void	Out.add(Source<T> source) Adds an upstream source to this flow output.

Uses of Source in com.asakusafw.vocabulary.flow.builder

Methods in com.asakusafw.vocabulary.flow.builder that return Source

Modifier and Type	Method and Description
<T> Source<T>	FlowElementEditor.createSource(String name, Class<T> type) Returns the Source object which represents output port of the target flow.
<T> Source<T>	FlowElementEditor.createSource(String name, Source<T> typeRef) Returns the Source object which represents output port of the target flow.

Methods in com.asakusafw.vocabulary.flow.builder with parameters of type Source

Modifier and Type	Method and Description
<T> Source<T>	FlowElementEditor.createSource(String name, Source<T> typeRef) Returns the Source object which represents output port of the target flow.
PortInfo	FlowElementBuilder.defineInput(String name, Source<?> upstream) Defines a new input for operator.
PortInfo	FlowElementBuilder.defineInput(String name, Source<?> upstream, FlowElementAttribute... attributes) Defines a new input for operator.
PortInfo	FlowElementBuilder.defineOutput(String name, Source<?> typeRef) Defines a new output for operator.
PortInfo	FlowElementBuilder.defineOutput(String name, Source<?> typeRef, FlowElementAttribute... attributes) Defines a new output for operator.

Uses of Source in com.asakusafw.vocabulary.flow.graph

Classes in com.asakusafw.vocabulary.flow.graph that implement Source

Modifier and Type	Class and Description
static class	FlowElementResolver.OutputDriver<T> An adapter class that enables FlowElementOutput performs as Source.
class	FlowIn<T> Represents an input of flow graph.

Methods in com.asakusafw.vocabulary.flow.graph that return Source

Modifier and Type	Method and Description
<T> Source<T>	FlowElementResolver.resolveOutput(String name) Returns the output port of the target flow element as upstream source.

Methods in com.asakusafw.vocabulary.flow.graph with parameters of type Source

Modifier and Type	Method and Description
void	FlowOut.add(Source<T> source)
OperatorDescription.Builder	OperatorDescription.Builder.addInput(String portName, Source<?> typeReference) Adds a new input port of the target operator.
OperatorDescription.Builder	OperatorDescription.Builder.addInput(String portName, Source<?> typeReference, ShuffleKey key) Adds a new input port of the target operator.
<T> FlowIn<T>	FlowPartDescription.Builder.addInput(String name, Source<T> typeReference) Add a new input port into the target flow-part.
OperatorDescription.Builder	OperatorDescription.Builder.addOutput(String portName, Source<?> typeReference) Adds a new output port of the target operator.
<T> FlowOut<T>	FlowPartDescription.Builder.addOutput(String name, Source<T> typeReference) Add a new output port into the target flow-part.
void	FlowElementResolver.resolveInput(String name, Source<?> source) Connects between an upstream source and the input port of the flow element.

Uses of Source in com.asakusafw.vocabulary.flow.testing

Classes in com.asakusafw.vocabulary.flow.testing that implement Source

Modifier and Type	Class and Description
class	MockIn<T> Mock implementation of In (for testing).

Methods in com.asakusafw.vocabulary.flow.testing with parameters of type Source

Modifier and Type	Method and Description
void	MockOut.add(Source<T> source)

Uses of Source in com.asakusafw.vocabulary.flow.util

Classes in com.asakusafw.vocabulary.flow.util that implement Source

Modifier and Type	Class and Description
static class	CoreOperatorFactory.Checkpoint<T> Represents a checkpoint operator which provides restarting point for (partial) failures.
static class	CoreOperatorFactory.Confluent<T> Represents a confluent operator which provides union of data-sets.
static class	CoreOperatorFactory.Empty<T> Represents an empty operator which provides empty data-sets.
static class	CoreOperatorFactory.Extend<T> Represents a extend operator which transforms data model objects into other data model types.
static class	CoreOperatorFactory.Project<T> Represents a project operator which transforms data model objects into other data model types.
static class	CoreOperatorFactory.Restructure<T> Represents a restructure operator which transforms data model objects into other data model types.

Fields in com.asakusafw.vocabulary.flow.util declared as Source

Modifier and Type	Field and Description
Source<T>	CoreOperatorFactory.Empty.out The singleton output of this operator.
Source<T>	CoreOperatorFactory.Confluent.out The singleton output of this operator.
Source<T>	CoreOperatorFactory.Checkpoint.out The singleton output of this operator.
Source<T>	CoreOperatorFactory.Project.out The singleton output of this operator.
Source<T>	CoreOperatorFactory.Extend.out The singleton output of this operator.
Source<T>	CoreOperatorFactory.Restructure.out The singleton output of this operator.

Methods in com.asakusafw.vocabulary.flow.util with parameters of type Source

Modifier and Type	Method and Description
<T> CoreOperatorFactory.Empty<T>	CoreOperatorFactory.EmptyFragment.as(Source<T> target) Creates a new empty operator instance from a source object which has the same type as the target (downstream) data model type.
<T> CoreOperatorFactory.Project<T>	CoreOperatorFactory.ProjectFragment.as(Source<T> target) Creates a new project operator instance from a source object which has the same type as the target (downstream) data model type.
<T> CoreOperatorFactory.Extend<T>	CoreOperatorFactory.ExtendFragment.as(Source<T> target) Creates a new extend operator instance from a source object which has the same type as the target (downstream) data model type.
<T> CoreOperatorFactory.Restructure<T>	CoreOperatorFactory.RestructureFragment.as(Source<T> target) Creates a new restructure operator instance from a source object which has the same type as the target (downstream) data model type.
static <T> CoreOperatorFactory.Checkpoint<T>	CoreOperators.checkpoint(Source<T> in) Returns a new checkpoint operator.
<T> CoreOperatorFactory.Checkpoint<T>	CoreOperatorFactory.checkpoint(Source<T> in) Returns a new checkpoint operator.
static <T> CoreOperatorFactory.Confluent<T>	CoreOperators.confluent(Source<T>... inputs) Returns a new confluent operator instance.
<T> CoreOperatorFactory.Confluent<T>	CoreOperatorFactory.confluent(Source<T>... inputs) Returns a new confluent operator instance.
static <T> CoreOperatorFactory.Confluent<T>	CoreOperators.confluent(Source<T> a, Source<T> b) Returns a new confluent operator instance.
static <T> CoreOperatorFactory.Confluent<T>	CoreOperators.confluent(Source<T> a, Source<T> b) Returns a new confluent operator instance.
<T> CoreOperatorFactory.Confluent<T>	CoreOperatorFactory.confluent(Source<T> a, Source<T> b) Returns a new confluent operator instance.
<T> CoreOperatorFactory.Confluent<T>	CoreOperatorFactory.confluent(Source<T> a, Source<T> b) Returns a new confluent operator instance.
static <T> CoreOperatorFactory.Confluent<T>	CoreOperators.confluent(Source<T> a, Source<T> b, Source<T> c) Returns a new confluent operator instance.
static <T> CoreOperatorFactory.Confluent<T>	CoreOperators.confluent(Source<T> a, Source<T> b, Source<T> c) Returns a new confluent operator instance.
static <T> CoreOperatorFactory.Confluent<T>	CoreOperators.confluent(Source<T> a, Source<T> b, Source<T> c) Returns a new confluent operator instance.
<T> CoreOperatorFactory.Confluent<T>	CoreOperatorFactory.confluent(Source<T> a, Source<T> b, Source<T> c) Returns a new confluent operator instance.
<T> CoreOperatorFactory.Confluent<T>	CoreOperatorFactory.confluent(Source<T> a, Source<T> b, Source<T> c) Returns a new confluent operator instance.
<T> CoreOperatorFactory.Confluent<T>	CoreOperatorFactory.confluent(Source<T> a, Source<T> b, Source<T> c) Returns a new confluent operator instance.
static <T> CoreOperatorFactory.Confluent<T>	CoreOperators.confluent(Source<T> a, Source<T> b, Source<T> c, Source<T> d) Returns a new confluent operator instance.
static <T> CoreOperatorFactory.Confluent<T>	CoreOperators.confluent(Source<T> a, Source<T> b, Source<T> c, Source<T> d) Returns a new confluent operator instance.
static <T> CoreOperatorFactory.Confluent<T>	CoreOperators.confluent(Source<T> a, Source<T> b, Source<T> c, Source<T> d) Returns a new confluent operator instance.
static <T> CoreOperatorFactory.Confluent<T>	CoreOperators.confluent(Source<T> a, Source<T> b, Source<T> c, Source<T> d) Returns a new confluent operator instance.
<T> CoreOperatorFactory.Confluent<T>	CoreOperatorFactory.confluent(Source<T> a, Source<T> b, Source<T> c, Source<T> d) Returns a new confluent operator instance.
<T> CoreOperatorFactory.Confluent<T>	CoreOperatorFactory.confluent(Source<T> a, Source<T> b, Source<T> c, Source<T> d) Returns a new confluent operator instance.
<T> CoreOperatorFactory.Confluent<T>	CoreOperatorFactory.confluent(Source<T> a, Source<T> b, Source<T> c, Source<T> d) Returns a new confluent operator instance.
<T> CoreOperatorFactory.Confluent<T>	CoreOperatorFactory.confluent(Source<T> a, Source<T> b, Source<T> c, Source<T> d) Returns a new confluent operator instance.
static CoreOperatorFactory.ExtendFragment	CoreOperators.extend(Source<?> in) Returns a new fragment which will be provide an extend operator.
CoreOperatorFactory.ExtendFragment	CoreOperatorFactory.extend(Source<?> in) Returns a new fragment which will be provide an extend operator.
static <T> CoreOperatorFactory.Extend<T>	CoreOperators.extend(Source<?> in, Class<T> targetType) Returns a new extend operator instance.
<T> CoreOperatorFactory.Extend<T>	CoreOperatorFactory.extend(Source<?> in, Class<T> targetType) Returns a new extend operator instance.
static CoreOperatorFactory.ProjectFragment	CoreOperators.project(Source<?> in) Returns a new fragment which will be provide a project operator.
CoreOperatorFactory.ProjectFragment	CoreOperatorFactory.project(Source<?> in) Returns a new fragment which will be provide a project operator.
static <T> CoreOperatorFactory.Project<T>	CoreOperators.project(Source<?> in, Class<T> targetType) Returns a new project operator instance.
<T> CoreOperatorFactory.Project<T>	CoreOperatorFactory.project(Source<?> in, Class<T> targetType) Returns a new project operator instance.
static CoreOperatorFactory.RestructureFragment	CoreOperators.restructure(Source<?> in) Returns a new fragment which will be provide a restructure operator.
CoreOperatorFactory.RestructureFragment	CoreOperatorFactory.restructure(Source<?> in) Returns a new fragment which will be provide a restructure operator.
static <T> CoreOperatorFactory.Restructure<T>	CoreOperators.restructure(Source<?> in, Class<T> targetType) Returns a new restructure operator instance.
<T> CoreOperatorFactory.Restructure<T>	CoreOperatorFactory.restructure(Source<?> in, Class<T> targetType) Returns a new restructure operator instance.
static void	CoreOperators.stop(Source<?> in) Terminates the upstream source.
void	CoreOperatorFactory.stop(Source<?> in) Terminates the upstream source.

Method parameters in com.asakusafw.vocabulary.flow.util with type arguments of type Source

Modifier and Type	Method and Description
static <T> CoreOperatorFactory.Confluent<T>	CoreOperators.confluent(Iterable<? extends Source<T>> inputs) Returns a new confluent operator instance.
<T> CoreOperatorFactory.Confluent<T>	CoreOperatorFactory.confluent(Iterable<? extends Source<T>> inputs) Returns a new confluent operator instance.