org.apache.flink.streaming.api.transformations

Class SideOutputTransformation<T>

java.lang.Object

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

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

Type Parameters:

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

public class SideOutputTransformation<T>
extends Transformation<T>

This transformation represents a selection of a side output of an upstream operation with a given OutputTag.

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 and Description
SideOutputTransformation(Transformation<?> input, OutputTag<T> tag)

Method Summary

Modifier and Type	Method and Description
List<Transformation<?>>	getInputs() Returns the transformations that are the immediate predecessors of the current transformation in the transformation graph.
OutputTag<T>	getOutputTag()
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, 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

Methods inherited from class java.lang.Object

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

Constructor Detail

SideOutputTransformation

public SideOutputTransformation(Transformation<?> input,
                                OutputTag<T> tag)

Method Detail

getOutputTag

public OutputTag<T> getOutputTag()

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>