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

Class OneInputTransformation<IN,OUT>

java.lang.Object

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

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

org.apache.flink.streaming.api.transformations.OneInputTransformation<IN,OUT>

Type Parameters:

IN - The type of the elements in the input Transformation

OUT - The type of the elements that result from this OneInputTransformation

@Internal
public class OneInputTransformation<IN,OUT>
extends PhysicalTransformation<OUT>

This Transformation represents the application of a OneInputStreamOperator to one input Transformation.

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
OneInputTransformation(org.apache.flink.api.dag.Transformation<IN> input, String name, OneInputStreamOperator<IN,OUT> operator, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType, int parallelism)	Creates a new OneInputTransformation from the given input and operator.
OneInputTransformation(org.apache.flink.api.dag.Transformation<IN> input, String name, OneInputStreamOperator<IN,OUT> operator, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType, int parallelism, boolean parallelismConfigured)
OneInputTransformation(org.apache.flink.api.dag.Transformation<IN> input, String name, StreamOperatorFactory<OUT> operatorFactory, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType, int parallelism)
OneInputTransformation(org.apache.flink.api.dag.Transformation<IN> input, String name, StreamOperatorFactory<OUT> operatorFactory, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType, int parallelism, boolean parallelismConfigured)	Creates a new LegacySinkTransformation from the given input Transformation.

Method Summary

Modifier and Type	Method	Description
List<org.apache.flink.api.dag.Transformation<?>>	getInputs()
org.apache.flink.api.common.typeinfo.TypeInformation<IN>	getInputType()	Returns the TypeInformation for the elements of the input.
OneInputStreamOperator<IN,OUT>	getOperator()
StreamOperatorFactory<OUT>	getOperatorFactory()	Returns the StreamOperatorFactory of this Transformation.
org.apache.flink.api.java.functions.KeySelector<IN,?>	getStateKeySelector()	Returns the KeySelector that must be used for partitioning keyed state in this Operation.
org.apache.flink.api.common.typeinfo.TypeInformation<?>	getStateKeyType()
List<org.apache.flink.api.dag.Transformation<?>>	getTransitivePredecessors()
void	setChainingStrategy(ChainingStrategy strategy)	Sets the chaining strategy of this Transformation.
void	setStateKeySelector(org.apache.flink.api.java.functions.KeySelector<IN,?> stateKeySelector)	Sets the KeySelector that must be used for partitioning keyed state of this operation.
void	setStateKeyType(org.apache.flink.api.common.typeinfo.TypeInformation<?> stateKeyType)

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

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

OneInputTransformation

public OneInputTransformation(org.apache.flink.api.dag.Transformation<IN> input,
                              String name,
                              OneInputStreamOperator<IN,OUT> operator,
                              org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType,
                              int parallelism)

Creates a new OneInputTransformation from the given input and operator.

Parameters:

input - The input Transformation

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

operator - The TwoInputStreamOperator

outputType - The type of the elements produced by this OneInputTransformation

parallelism - The parallelism of this OneInputTransformation

OneInputTransformation

public OneInputTransformation(org.apache.flink.api.dag.Transformation<IN> input,
                              String name,
                              OneInputStreamOperator<IN,OUT> operator,
                              org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType,
                              int parallelism,
                              boolean parallelismConfigured)

OneInputTransformation

public OneInputTransformation(org.apache.flink.api.dag.Transformation<IN> input,
                              String name,
                              StreamOperatorFactory<OUT> operatorFactory,
                              org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType,
                              int parallelism)

OneInputTransformation

public OneInputTransformation(org.apache.flink.api.dag.Transformation<IN> input,
                              String name,
                              StreamOperatorFactory<OUT> operatorFactory,
                              org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType,
                              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

operatorFactory - The TwoInputStreamOperator factory

outputType - The type of the elements produced by this OneInputTransformation

parallelism - The parallelism of this OneInputTransformation

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

Method Detail

getInputType

public org.apache.flink.api.common.typeinfo.TypeInformation<IN> getInputType()

Returns the TypeInformation for the elements of the input.

getOperator

@VisibleForTesting
public OneInputStreamOperator<IN,OUT> getOperator()

getOperatorFactory

public StreamOperatorFactory<OUT> getOperatorFactory()

Returns the StreamOperatorFactory of this Transformation.

setStateKeySelector

public void setStateKeySelector(org.apache.flink.api.java.functions.KeySelector<IN,?> stateKeySelector)

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

Parameters:

stateKeySelector - The KeySelector to set

getStateKeySelector

public org.apache.flink.api.java.functions.KeySelector<IN,?> getStateKeySelector()

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

See Also:

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

setStateKeyType

public void setStateKeyType(org.apache.flink.api.common.typeinfo.TypeInformation<?> stateKeyType)

getStateKeyType

public org.apache.flink.api.common.typeinfo.TypeInformation<?> getStateKeyType()

getTransitivePredecessors

public List<org.apache.flink.api.dag.Transformation<?>> getTransitivePredecessors()

Specified by:

getTransitivePredecessors in class org.apache.flink.api.dag.Transformation<OUT>

getInputs

public List<org.apache.flink.api.dag.Transformation<?>> getInputs()

Specified by:

getInputs in class org.apache.flink.api.dag.Transformation<OUT>

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