org.apache.flink.streaming.api.transformations

Class TwoInputTransformation<IN1,IN2,OUT>

java.lang.Object

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

org.apache.flink.streaming.api.transformations.TwoInputTransformation<IN1,IN2,OUT>

Type Parameters:

IN1 - The type of the elements in the first input StreamTransformation

IN2 - The type of the elements in the second input StreamTransformation

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

@Internal
public class TwoInputTransformation<IN1,IN2,OUT>
extends StreamTransformation<OUT>

This Transformation represents the application of a TwoInputStreamOperator to two input StreamTransformations. The result is again only one stream.

Field Summary

Fields inherited from class org.apache.flink.streaming.api.transformations.StreamTransformation

bufferTimeout, id, idCounter, name, outputType, typeUsed

Constructor Summary

Constructors

Constructor and Description
TwoInputTransformation(StreamTransformation<IN1> input1, StreamTransformation<IN2> input2, String name, TwoInputStreamOperator<IN1,IN2,OUT> operator, TypeInformation<OUT> outputType, int parallelism) Creates a new TwoInputTransformation from the given inputs and operator.

Method Summary

Modifier and Type	Method and Description
StreamTransformation<IN1>	getInput1() Returns the first input StreamTransformation of this TwoInputTransformation.
StreamTransformation<IN2>	getInput2() Returns the first input StreamTransformation of this TwoInputTransformation.
TypeInformation<IN1>	getInputType1() Returns the TypeInformation for the elements from the first input.
TypeInformation<IN2>	getInputType2() Returns the TypeInformation for the elements from the first input.
TwoInputStreamOperator<IN1,IN2,OUT>	getOperator() Returns the TwoInputStreamOperator of this Transformation.
KeySelector<IN1,?>	getStateKeySelector1() Returns the KeySelector that must be used for partitioning keyed state in this Operation for the first input.
KeySelector<IN2,?>	getStateKeySelector2() Returns the KeySelector that must be used for partitioning keyed state in this Operation for the second input.
TypeInformation<?>	getStateKeyType()
Collection<StreamTransformation<?>>	getTransitivePredecessors() Returns all transitive predecessor StreamTransformations of this StreamTransformation.
void	setChainingStrategy(ChainingStrategy strategy) Sets the chaining strategy of this StreamTransformation.
void	setStateKeySelectors(KeySelector<IN1,?> stateKeySelector1, KeySelector<IN2,?> stateKeySelector2) Sets the KeySelectors that must be used for partitioning keyed state of this transformation.
void	setStateKeyType(TypeInformation<?> stateKeyType)

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

equals, getBufferTimeout, getId, getName, getNewNodeId, getOutputType, getParallelism, getSlotSharingGroup, getUid, hashCode, setBufferTimeout, setName, setOutputType, setParallelism, setSlotSharingGroup, setUid, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

TwoInputTransformation

public TwoInputTransformation(StreamTransformation<IN1> input1,
                              StreamTransformation<IN2> input2,
                              String name,
                              TwoInputStreamOperator<IN1,IN2,OUT> operator,
                              TypeInformation<OUT> outputType,
                              int parallelism)

Creates a new TwoInputTransformation from the given inputs and operator.

Parameters:

input1 - The first input StreamTransformation

input2 - The second input StreamTransformation

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

operator - The TwoInputStreamOperator

outputType - The type of the elements produced by this Transformation

parallelism - The parallelism of this Transformation

Method Detail

getInput1

public StreamTransformation<IN1> getInput1()

Returns the first input StreamTransformation of this TwoInputTransformation.

getInput2

public StreamTransformation<IN2> getInput2()

Returns the first input StreamTransformation of this TwoInputTransformation.

getInputType1

public TypeInformation<IN1> getInputType1()

Returns the TypeInformation for the elements from the first input.

getInputType2

public TypeInformation<IN2> getInputType2()

Returns the TypeInformation for the elements from the first input.

getOperator

public TwoInputStreamOperator<IN1,IN2,OUT> getOperator()

Returns the TwoInputStreamOperator of this Transformation.

setStateKeySelectors

public void setStateKeySelectors(KeySelector<IN1,?> stateKeySelector1,
                                 KeySelector<IN2,?> stateKeySelector2)

Sets the KeySelectors that must be used for partitioning keyed state of this transformation.

Parameters:

stateKeySelector1 - The KeySelector to set for the first input

stateKeySelector2 - The KeySelector to set for the first input

getStateKeySelector1

public KeySelector<IN1,?> getStateKeySelector1()

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

See Also:

setStateKeySelectors(org.apache.flink.api.java.functions.KeySelector<IN1, ?>, org.apache.flink.api.java.functions.KeySelector<IN2, ?>)

getStateKeySelector2

public KeySelector<IN2,?> getStateKeySelector2()

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

See Also:

setStateKeySelectors(org.apache.flink.api.java.functions.KeySelector<IN1, ?>, org.apache.flink.api.java.functions.KeySelector<IN2, ?>)

setStateKeyType

public void setStateKeyType(TypeInformation<?> stateKeyType)

getStateKeyType

public TypeInformation<?> getStateKeyType()

getTransitivePredecessors

public Collection<StreamTransformation<?>> getTransitivePredecessors()

Description copied from class: StreamTransformation

Returns all transitive predecessor StreamTransformations of this StreamTransformation. 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 StreamTransformation<OUT>

Returns:

The list of transitive predecessors.

setChainingStrategy

public final void setChainingStrategy(ChainingStrategy strategy)

Description copied from class: StreamTransformation

Sets the chaining strategy of this StreamTransformation.

Specified by:

setChainingStrategy in class StreamTransformation<OUT>