T
- The type of the elements that result from this SelectTransformation
@Internal public class SelectTransformation<T> extends Transformation<T>
SplitTransformation
that
splits elements into several logical streams with assigned names.
This does not create a physical operation, it only affects how upstream operations are connected to downstream operations.
bufferTimeout, DEFAULT_MANAGED_MEMORY_WEIGHT, id, idCounter, name, outputType, typeUsed, UPPER_BOUND_MAX_PARALLELISM
Constructor and Description |
---|
SelectTransformation(Transformation<T> input,
List<String> selectedNames)
Creates a new
SelectionTransformation from the given input that only selects
the streams with the selected names. |
Modifier and Type | Method and Description |
---|---|
Transformation<T> |
getInput()
Returns the input
Transformation . |
List<String> |
getSelectedNames()
Returns the names of the split streams that this
SelectTransformation selects. |
Collection<Transformation<?>> |
getTransitivePredecessors()
Returns all transitive predecessor
Transformation s 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 SelectTransformation(Transformation<T> input, List<String> selectedNames)
SelectionTransformation
from the given input that only selects
the streams with the selected names.input
- The input Transformation
selectedNames
- The names from the upstream SplitTransformation
that this
SelectTransformation
selects.public Transformation<T> getInput()
Transformation
.public List<String> getSelectedNames()
SelectTransformation
selects.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.