Package org.apache.flink.streaming.api.transformations

Class PartitionTransformation<T>

java.lang.Object

org.apache.flink.api.dag.Transformation<T>

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

Type Parameters:

T - The type of the elements that result from this PartitionTransformation

@Internal
public class PartitionTransformation<T>
extends Transformation<T>

This transformation represents a change of partitioning of the input elements.

This does not create a physical operation, it only affects how upstream operations are connected to downstream operations.

Field Summary

Fields inherited from class org.apache.flink.api.dag.Transformation

bufferTimeout, description, id, name, outputType, typeUsed, UPPER_BOUND_MAX_PARALLELISM

Constructor Summary

Constructors

Constructor	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.

Method Summary

Modifier and Type	Method	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 Transformations of this Transformation.

Methods inherited from class org.apache.flink.api.dag.Transformation

declareManagedMemoryUseCaseAtOperatorScope, declareManagedMemoryUseCaseAtSlotScope, equals, getAttribute, getBufferTimeout, getCoLocationGroupKey, getDescription, getId, getManagedMemoryOperatorScopeUseCaseWeights, getManagedMemorySlotScopeUseCases, getMaxParallelism, getMinResources, getName, getNewNodeId, getOutputType, getParallelism, getPreferredResources, getSlotSharingGroup, getTransitivePredecessors, getUid, getUserProvidedNodeHash, hashCode, isParallelismConfigured, setAttribute, setBufferTimeout, setCoLocationGroupKey, setDescription, setMaxParallelism, setName, setOutputType, setParallelism, setParallelism, setResources, setSlotSharingGroup, setSlotSharingGroup, setUid, setUidHash, toString, updateManagedMemoryStateBackendUseCase

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionTransformation

public PartitionTransformation(Transformation<T> input,
                               StreamPartitioner<T> partitioner)

Creates a new PartitionTransformation from the given input and StreamPartitioner.

Parameters:

input - The input Transformation

partitioner - The StreamPartitioner

PartitionTransformation

public PartitionTransformation(Transformation<T> input,
                               StreamPartitioner<T> partitioner,
                               StreamExchangeMode exchangeMode)

Creates a new PartitionTransformation from the given input and StreamPartitioner.

Parameters:

input - The input Transformation

partitioner - The StreamPartitioner

exchangeMode - The StreamExchangeMode

Method Detail

getPartitioner

public StreamPartitioner<T> getPartitioner()

Returns the StreamPartitioner that must be used for partitioning the elements of the input Transformation.

getExchangeMode

public StreamExchangeMode getExchangeMode()

Returns the StreamExchangeMode of this PartitionTransformation.

getTransitivePredecessorsInternal

protected List<Transformation<?>> getTransitivePredecessorsInternal()

Description copied from class: Transformation

Returns all transitive predecessor Transformations 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.

Specified by:

getTransitivePredecessorsInternal in class Transformation<T>

Returns:

The list of transitive predecessors.

getInputs

public List<Transformation<?>> getInputs()

Description copied from class: Transformation

Returns the transformations that are the immediate predecessors of the current transformation in the transformation graph.

Specified by:

getInputs in class Transformation<T>