org.apache.flink.streaming.api.transformations

Class LegacySinkTransformation<T>

java.lang.Object

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

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

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

Type Parameters:

T - The type of the elements in the input LegacySinkTransformation

@Internal
public class LegacySinkTransformation<T>
extends PhysicalTransformation<T>

This Transformation represents a stream Sink.

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
LegacySinkTransformation(Transformation<T> input, String name, StreamOperatorFactory<Object> operatorFactory, int parallelism)
LegacySinkTransformation(Transformation<T> input, String name, StreamOperatorFactory<Object> operatorFactory, int parallelism, boolean parallelismConfigured)
LegacySinkTransformation(Transformation<T> input, String name, StreamSink<T> operator, int parallelism, boolean parallelismConfigured) Creates a new LegacySinkTransformation from the given input Transformation.

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.
StreamSink<T>	getOperator()
StreamOperatorFactory<Object>	getOperatorFactory() Returns the StreamOperatorFactory of this LegacySinkTransformation.
KeySelector<T,?>	getStateKeySelector() Returns the KeySelector that must be used for partitioning keyed state in this Sink.
TypeInformation<?>	getStateKeyType()
List<Transformation<?>>	getTransitivePredecessors() Returns all transitive predecessor Transformations of this Transformation.
boolean	isSupportsConcurrentExecutionAttempts()
void	setChainingStrategy(ChainingStrategy strategy) Sets the chaining strategy of this Transformation.
void	setStateKeySelector(KeySelector<T,?> stateKeySelector) Sets the KeySelector that must be used for partitioning keyed state of this Sink.
void	setStateKeyType(TypeInformation<?> stateKeyType)

Methods inherited from class org.apache.flink.streaming.api.transformations.PhysicalTransformation

setSupportsConcurrentExecutionAttempts

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, 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

LegacySinkTransformation

public LegacySinkTransformation(Transformation<T> input,
                                String name,
                                StreamSink<T> operator,
                                int parallelism,
                                boolean parallelismConfigured)

Creates a new LegacySinkTransformation from the given input Transformation.

Parameters:

input - The input Transformation

name - The name of the Transformation, this will be shown in Visualizations and the Log

operator - The sink operator

parallelism - The parallelism of this LegacySinkTransformation

parallelismConfigured - If true, the parallelism of the transformation is explicitly set and should be respected. Otherwise the parallelism can be changed at runtime.

LegacySinkTransformation

public LegacySinkTransformation(Transformation<T> input,
                                String name,
                                StreamOperatorFactory<Object> operatorFactory,
                                int parallelism)

LegacySinkTransformation

public LegacySinkTransformation(Transformation<T> input,
                                String name,
                                StreamOperatorFactory<Object> operatorFactory,
                                int parallelism,
                                boolean parallelismConfigured)

Method Detail

getOperator

@VisibleForTesting
public StreamSink<T> getOperator()

getOperatorFactory

public StreamOperatorFactory<Object> getOperatorFactory()

Returns the StreamOperatorFactory of this LegacySinkTransformation.

setStateKeySelector

public void setStateKeySelector(KeySelector<T,?> stateKeySelector)

Sets the KeySelector that must be used for partitioning keyed state of this Sink.

Parameters:

stateKeySelector - The KeySelector to set

getStateKeySelector

public KeySelector<T,?> getStateKeySelector()

Returns the KeySelector that must be used for partitioning keyed state in this Sink.

See Also:

setStateKeySelector(org.apache.flink.api.java.functions.KeySelector<T, ?>)

setStateKeyType

public void setStateKeyType(TypeInformation<?> stateKeyType)

getStateKeyType

public TypeInformation<?> getStateKeyType()

getTransitivePredecessors

public List<Transformation<?>> getTransitivePredecessors()

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:

getTransitivePredecessors 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>

setChainingStrategy

public final void setChainingStrategy(ChainingStrategy strategy)

Description copied from class: PhysicalTransformation

Sets the chaining strategy of this Transformation.

Specified by:

setChainingStrategy in class PhysicalTransformation<T>

isSupportsConcurrentExecutionAttempts

public boolean isSupportsConcurrentExecutionAttempts()

Overrides:

isSupportsConcurrentExecutionAttempts in class PhysicalTransformation<T>