@Internal public class SourceTransformation<OUT> extends PhysicalTransformation<OUT>
PhysicalTransformation
for Source
.bufferTimeout, DEFAULT_MANAGED_MEMORY_WEIGHT, id, idCounter, name, outputType, typeUsed, UPPER_BOUND_MAX_PARALLELISM
Constructor and Description |
---|
SourceTransformation(String name,
SourceOperatorFactory<OUT> sourceFactory,
TypeInformation<OUT> outputType,
int parallelism)
Creates a new
Transformation with the given name, output type and parallelism. |
Modifier and Type | Method and Description |
---|---|
SourceOperatorFactory<OUT> |
getOperatorFactory()
Returns the
StreamOperatorFactory of this LegacySourceTransformation . |
Collection<Transformation<?>> |
getTransitivePredecessors()
Returns all transitive predecessor
Transformation s of this Transformation . |
void |
setChainingStrategy(ChainingStrategy strategy)
Sets the chaining strategy of this
Transformation . |
equals, getBufferTimeout, getCoLocationGroupKey, getId, getManagedMemoryWeight, getMaxParallelism, getMinResources, getName, getNewNodeId, getOutputType, getParallelism, getPreferredResources, getSlotSharingGroup, getUid, getUserProvidedNodeHash, hashCode, setBufferTimeout, setCoLocationGroupKey, setManagedMemoryWeight, setMaxParallelism, setName, setOutputType, setParallelism, setResources, setSlotSharingGroup, setUid, setUidHash, toString
public SourceTransformation(String name, SourceOperatorFactory<OUT> sourceFactory, TypeInformation<OUT> outputType, int parallelism)
Transformation
with the given name, output type and parallelism.name
- The name of the Transformation
, this will be shown in Visualizations and
the LogsourceFactory
- The operator factory for SourceOperator
.outputType
- The output type of this Transformation
parallelism
- The parallelism of this Transformation
public SourceOperatorFactory<OUT> getOperatorFactory()
StreamOperatorFactory
of this LegacySourceTransformation
.public Collection<Transformation<?>> getTransitivePredecessors()
Transformation
Transformation
s of this Transformation
.
This is, for example, used when determining whether a feedback edge of an iteration actually
has the iteration head as a predecessor.getTransitivePredecessors
in class Transformation<OUT>
public final void setChainingStrategy(ChainingStrategy strategy)
PhysicalTransformation
Transformation
.setChainingStrategy
in class PhysicalTransformation<OUT>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.