T
- The type of the elements that result from this UnionTransformation
@Internal public class UnionTransformation<T> extends Transformation<T>
Transformations
.
This does not create a physical operation, it only affects how upstream operations are connected to downstream operations.
bufferTimeout, id, idCounter, name, outputType, typeUsed, UPPER_BOUND_MAX_PARALLELISM
Constructor and Description |
---|
UnionTransformation(List<Transformation<T>> inputs)
Creates a new
UnionTransformation from the given input Transformations . |
Modifier and Type | Method and Description |
---|---|
List<Transformation<T>> |
getInputs()
Returns the list of input
Transformations . |
Collection<Transformation<?>> |
getTransitivePredecessors()
Returns all transitive predecessor
Transformation s of this Transformation . |
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
public UnionTransformation(List<Transformation<T>> inputs)
UnionTransformation
from the given input Transformations
.
The input Transformations
must all have the same type.
inputs
- The list of input Transformations
public List<Transformation<T>> getInputs()
Transformations
.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<T>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.