T
- The type of the elements in the input SinkTransformation
@Internal public class SinkTransformation<T> extends PhysicalTransformation<Object>
bufferTimeout, DEFAULT_MANAGED_MEMORY_WEIGHT, id, idCounter, name, outputType, typeUsed, UPPER_BOUND_MAX_PARALLELISM
Constructor and Description |
---|
SinkTransformation(Transformation<T> input,
String name,
StreamOperatorFactory<Object> operatorFactory,
int parallelism) |
SinkTransformation(Transformation<T> input,
String name,
StreamSink<T> operator,
int parallelism)
Creates a new
SinkTransformation from the given input Transformation . |
Modifier and Type | Method and Description |
---|---|
Transformation<T> |
getInput()
Returns the input
Transformation of this SinkTransformation . |
StreamSink<T> |
getOperator() |
StreamOperatorFactory<Object> |
getOperatorFactory()
Returns the
StreamOperatorFactory of this SinkTransformation . |
KeySelector<T,?> |
getStateKeySelector()
Returns the
KeySelector that must be used for partitioning keyed state in this
Sink. |
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 |
setStateKeySelector(KeySelector<T,?> stateKeySelector)
Sets the
KeySelector that must be used for partitioning keyed state of this Sink. |
void |
setStateKeyType(TypeInformation<?> stateKeyType) |
equals, getBufferTimeout, getCoLocationGroupKey, getId, getManagedMemoryWeight, getMaxParallelism, getMinResources, getName, getNewNodeId, getOutputType, getParallelism, getPreferredResources, getSlotSharingGroup, getUid, getUserProvidedNodeHash, hashCode, setBufferTimeout, setCoLocationGroupKey, setManagedMemoryWeight, setMaxParallelism, setName, setOutputType, setParallelism, setResources, setSlotSharingGroup, setUid, setUidHash, toString
public SinkTransformation(Transformation<T> input, String name, StreamSink<T> operator, int parallelism)
SinkTransformation
from the given input Transformation
.input
- The input Transformation
name
- The name of the Transformation
, this will be shown in Visualizations and the Logoperator
- The sink operatorparallelism
- The parallelism of this SinkTransformation
public SinkTransformation(Transformation<T> input, String name, StreamOperatorFactory<Object> operatorFactory, int parallelism)
public Transformation<T> getInput()
Transformation
of this SinkTransformation
.@VisibleForTesting public StreamSink<T> getOperator()
public StreamOperatorFactory<Object> getOperatorFactory()
StreamOperatorFactory
of this SinkTransformation
.public void setStateKeySelector(KeySelector<T,?> stateKeySelector)
KeySelector
that must be used for partitioning keyed state of this Sink.stateKeySelector
- The KeySelector
to setpublic KeySelector<T,?> getStateKeySelector()
KeySelector
that must be used for partitioning keyed state in this
Sink.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<Object>
public final void setChainingStrategy(ChainingStrategy strategy)
PhysicalTransformation
Transformation
.setChainingStrategy
in class PhysicalTransformation<Object>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.