org.apache.flink.streaming.api.transformations

Class SourceTransformation<T>

java.lang.Object

org.apache.flink.streaming.api.transformations.StreamTransformation<T>

org.apache.flink.streaming.api.transformations.SourceTransformation<T>

Type Parameters:

T - The type of the elements that this source produces

@Internal
public class SourceTransformation<T>
extends StreamTransformation<T>

This represents a Source. This does not actually transform anything since it has no inputs but it is the root StreamTransformation of any topology.

Field Summary

Fields inherited from class org.apache.flink.streaming.api.transformations.StreamTransformation

bufferTimeout, id, idCounter, name, outputType, typeUsed

Constructor Summary

Constructors

Constructor and Description
SourceTransformation(String name, StreamSource<T,?> operator, TypeInformation<T> outputType, int parallelism) Creates a new SourceTransformation from the given operator.

Method Summary

Modifier and Type	Method and Description
StreamSource<T,?>	getOperator() Returns the StreamSource, the operator of this SourceTransformation.
Collection<StreamTransformation<?>>	getTransitivePredecessors() Returns all transitive predecessor StreamTransformations of this StreamTransformation.
void	setChainingStrategy(ChainingStrategy strategy) Sets the chaining strategy of this StreamTransformation.

Methods inherited from class org.apache.flink.streaming.api.transformations.StreamTransformation

equals, getBufferTimeout, getCoLocationGroupKey, getId, getMaxParallelism, getMinResources, getName, getNewNodeId, getOutputType, getParallelism, getPreferredResources, getSlotSharingGroup, getUid, getUserProvidedNodeHash, hashCode, setBufferTimeout, setCoLocationGroupKey, setMaxParallelism, setName, setOutputType, setParallelism, setResources, setSlotSharingGroup, setUid, setUidHash, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

SourceTransformation

public SourceTransformation(String name,
                            StreamSource<T,?> operator,
                            TypeInformation<T> outputType,
                            int parallelism)

Creates a new SourceTransformation from the given operator.

Parameters:

name - The name of the SourceTransformation, this will be shown in Visualizations and the Log

operator - The StreamSource that is the operator of this Transformation

outputType - The type of the elements produced by this SourceTransformation

parallelism - The parallelism of this SourceTransformation

Method Detail

getOperator

public StreamSource<T,?> getOperator()

Returns the StreamSource, the operator of this SourceTransformation.

getTransitivePredecessors

public Collection<StreamTransformation<?>> getTransitivePredecessors()

Description copied from class: StreamTransformation

Returns all transitive predecessor StreamTransformations of this StreamTransformation. This is, for example, used when determining whether a feedback edge of an iteration actually has the iteration head as a predecessor.

Specified by:

getTransitivePredecessors in class StreamTransformation<T>

Returns:

The list of transitive predecessors.

setChainingStrategy

public final void setChainingStrategy(ChainingStrategy strategy)

Description copied from class: StreamTransformation

Sets the chaining strategy of this StreamTransformation.

Specified by:

setChainingStrategy in class StreamTransformation<T>