IN1
- The type of the elements in the first input Transformation
IN2
- The type of the elements in the second input Transformation
OUT
- The type of the elements that result from this TwoInputTransformation
@Internal public class TwoInputTransformation<IN1,IN2,OUT> extends PhysicalTransformation<OUT>
TwoInputStreamOperator
to two input Transformations
.
The result is again only one stream.bufferTimeout, id, idCounter, name, outputType, typeUsed, UPPER_BOUND_MAX_PARALLELISM
Constructor and Description |
---|
TwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
String name,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<OUT> outputType,
int parallelism) |
TwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
String name,
TwoInputStreamOperator<IN1,IN2,OUT> operator,
TypeInformation<OUT> outputType,
int parallelism)
Creates a new
TwoInputTransformation from the given inputs and operator. |
Modifier and Type | Method and Description |
---|---|
Transformation<IN1> |
getInput1()
Returns the first input
Transformation of this TwoInputTransformation . |
Transformation<IN2> |
getInput2()
Returns the second input
Transformation 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 second input. |
TwoInputStreamOperator<IN1,IN2,OUT> |
getOperator() |
StreamOperatorFactory<OUT> |
getOperatorFactory()
Returns the
StreamOperatorFactory 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<Transformation<?>> |
getTransitivePredecessors()
Returns all transitive predecessor
Transformation s of this Transformation . |
void |
setChainingStrategy(ChainingStrategy strategy)
Sets the chaining strategy of this
Transformation . |
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) |
equals, getBufferTimeout, getCoLocationGroupKey, getId, getMaxParallelism, getMinResources, getName, getNewNodeId, getOutputType, getParallelism, getPreferredResources, getSlotSharingGroup, getUid, getUserProvidedNodeHash, hashCode, setBufferTimeout, setCoLocationGroupKey, setMaxParallelism, setName, setOutputType, setParallelism, setResources, setSlotSharingGroup, setUid, setUidHash, toString
public TwoInputTransformation(Transformation<IN1> input1, Transformation<IN2> input2, String name, TwoInputStreamOperator<IN1,IN2,OUT> operator, TypeInformation<OUT> outputType, int parallelism)
TwoInputTransformation
from the given inputs and operator.input1
- The first input Transformation
input2
- The second input Transformation
name
- The name of the Transformation
, this will be shown in Visualizations and the Logoperator
- The TwoInputStreamOperator
outputType
- The type of the elements produced by this Transformationparallelism
- The parallelism of this Transformationpublic TwoInputTransformation(Transformation<IN1> input1, Transformation<IN2> input2, String name, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<OUT> outputType, int parallelism)
public Transformation<IN1> getInput1()
Transformation
of this TwoInputTransformation
.public Transformation<IN2> getInput2()
Transformation
of this TwoInputTransformation
.public TypeInformation<IN1> getInputType1()
TypeInformation
for the elements from the first input.public TypeInformation<IN2> getInputType2()
TypeInformation
for the elements from the second input.@VisibleForTesting public TwoInputStreamOperator<IN1,IN2,OUT> getOperator()
public StreamOperatorFactory<OUT> getOperatorFactory()
StreamOperatorFactory
of this Transformation.public void setStateKeySelectors(KeySelector<IN1,?> stateKeySelector1, KeySelector<IN2,?> stateKeySelector2)
KeySelectors
that must be used for partitioning keyed state of
this transformation.stateKeySelector1
- The KeySelector
to set for the first inputstateKeySelector2
- The KeySelector
to set for the first inputpublic KeySelector<IN1,?> getStateKeySelector1()
KeySelector
that must be used for partitioning keyed state in this
Operation for the first input.public KeySelector<IN2,?> getStateKeySelector2()
KeySelector
that must be used for partitioning keyed state in this
Operation for the second input.public void setStateKeyType(TypeInformation<?> stateKeyType)
public TypeInformation<?> getStateKeyType()
public Collection<Transformation<?>> getTransitivePredecessors()
Transformation
Transformation
s 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.getTransitivePredecessors
in class Transformation<OUT>
public final void setChainingStrategy(ChainingStrategy strategy)
PhysicalTransformation
Transformation
.setChainingStrategy
in class PhysicalTransformation<OUT>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.