IN
- The type of the elements in the input StreamTransformation
OUT
- The type of the elements that result from this OneInputTransformation
@Internal public class OneInputTransformation<IN,OUT> extends StreamTransformation<OUT>
OneInputStreamOperator
to one input
StreamTransformation
.bufferTimeout, id, idCounter, name, outputType, typeUsed
Constructor and Description |
---|
OneInputTransformation(StreamTransformation<IN> input,
String name,
OneInputStreamOperator<IN,OUT> operator,
TypeInformation<OUT> outputType,
int parallelism)
Creates a new
OneInputTransformation from the given input and operator. |
Modifier and Type | Method and Description |
---|---|
StreamTransformation<IN> |
getInput()
Returns the input
StreamTransformation of this OneInputTransformation . |
TypeInformation<IN> |
getInputType()
Returns the
TypeInformation for the elements of the input. |
OneInputStreamOperator<IN,OUT> |
getOperator()
Returns the
TwoInputStreamOperator of this Transformation. |
KeySelector<IN,?> |
getStateKeySelector()
Returns the
KeySelector that must be used for partitioning keyed state in this
Operation. |
TypeInformation<?> |
getStateKeyType() |
Collection<StreamTransformation<?>> |
getTransitivePredecessors()
Returns all transitive predecessor
StreamTransformation s of this StreamTransformation . |
void |
setChainingStrategy(ChainingStrategy strategy)
Sets the chaining strategy of this
StreamTransformation . |
void |
setStateKeySelector(KeySelector<IN,?> stateKeySelector)
Sets the
KeySelector that must be used for partitioning keyed state of this operation. |
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 OneInputTransformation(StreamTransformation<IN> input, String name, OneInputStreamOperator<IN,OUT> operator, TypeInformation<OUT> outputType, int parallelism)
OneInputTransformation
from the given input and operator.input
- The input StreamTransformation
name
- The name of the StreamTransformation
, this will be shown in Visualizations and the Logoperator
- The TwoInputStreamOperator
outputType
- The type of the elements produced by this OneInputTransformation
parallelism
- The parallelism of this OneInputTransformation
public StreamTransformation<IN> getInput()
StreamTransformation
of this OneInputTransformation
.public TypeInformation<IN> getInputType()
TypeInformation
for the elements of the input.public OneInputStreamOperator<IN,OUT> getOperator()
TwoInputStreamOperator
of this Transformation.public void setStateKeySelector(KeySelector<IN,?> stateKeySelector)
KeySelector
that must be used for partitioning keyed state of this operation.stateKeySelector
- The KeySelector
to setpublic KeySelector<IN,?> getStateKeySelector()
KeySelector
that must be used for partitioning keyed state in this
Operation.public void setStateKeyType(TypeInformation<?> stateKeyType)
public TypeInformation<?> getStateKeyType()
public Collection<StreamTransformation<?>> getTransitivePredecessors()
StreamTransformation
StreamTransformation
s 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.getTransitivePredecessors
in class StreamTransformation<OUT>
public final void setChainingStrategy(ChainingStrategy strategy)
StreamTransformation
StreamTransformation
.setChainingStrategy
in class StreamTransformation<OUT>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.