T
- The type of the elements that result from this PartitionTransformation
@Internal public class PartitionTransformation<T> extends Transformation<T>
This does not create a physical operation, it only affects how upstream operations are connected to downstream operations.
bufferTimeout, description, id, name, outputType, typeUsed, UPPER_BOUND_MAX_PARALLELISM
Constructor and Description |
---|
PartitionTransformation(Transformation<T> input,
StreamPartitioner<T> partitioner)
Creates a new
PartitionTransformation from the given input and StreamPartitioner . |
PartitionTransformation(Transformation<T> input,
StreamPartitioner<T> partitioner,
StreamExchangeMode exchangeMode)
Creates a new
PartitionTransformation from the given input and StreamPartitioner . |
Modifier and Type | Method and Description |
---|---|
StreamExchangeMode |
getExchangeMode()
Returns the
StreamExchangeMode of this PartitionTransformation . |
List<Transformation<?>> |
getInputs()
Returns the
transformations that are the immediate predecessors of the
current transformation in the transformation graph. |
StreamPartitioner<T> |
getPartitioner()
Returns the
StreamPartitioner that must be used for partitioning the elements of the
input Transformation . |
protected List<Transformation<?>> |
getTransitivePredecessorsInternal()
Returns all transitive predecessor
Transformation s of this Transformation . |
declareManagedMemoryUseCaseAtOperatorScope, declareManagedMemoryUseCaseAtSlotScope, equals, getBufferTimeout, getCoLocationGroupKey, getDescription, getId, getManagedMemoryOperatorScopeUseCaseWeights, getManagedMemorySlotScopeUseCases, getMaxParallelism, getMinResources, getName, getNewNodeId, getOutputType, getParallelism, getPreferredResources, getSlotSharingGroup, getTransitivePredecessors, getUid, getUserProvidedNodeHash, hashCode, isParallelismConfigured, setBufferTimeout, setCoLocationGroupKey, setDescription, setMaxParallelism, setName, setOutputType, setParallelism, setParallelism, setResources, setSlotSharingGroup, setSlotSharingGroup, setUid, setUidHash, toString, updateManagedMemoryStateBackendUseCase
public PartitionTransformation(Transformation<T> input, StreamPartitioner<T> partitioner)
PartitionTransformation
from the given input and StreamPartitioner
.input
- The input Transformation
partitioner
- The StreamPartitioner
public PartitionTransformation(Transformation<T> input, StreamPartitioner<T> partitioner, StreamExchangeMode exchangeMode)
PartitionTransformation
from the given input and StreamPartitioner
.input
- The input Transformation
partitioner
- The StreamPartitioner
exchangeMode
- The StreamExchangeMode
public StreamPartitioner<T> getPartitioner()
StreamPartitioner
that must be used for partitioning the elements of the
input Transformation
.public StreamExchangeMode getExchangeMode()
StreamExchangeMode
of this PartitionTransformation
.protected List<Transformation<?>> getTransitivePredecessorsInternal()
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.getTransitivePredecessorsInternal
in class Transformation<T>
public List<Transformation<?>> getInputs()
Transformation
transformations
that are the immediate predecessors of the
current transformation in the transformation graph.getInputs
in class Transformation<T>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.