InputT
- The input type of the SinkWriter
OutputT
- The output type of the Sink
@Internal public class SinkTransformation<InputT,OutputT> extends PhysicalTransformation<OutputT>
Transformation
for Sink
.bufferTimeout, description, id, idCounter, name, outputType, typeUsed, UPPER_BOUND_MAX_PARALLELISM
Constructor and Description |
---|
SinkTransformation(DataStream<InputT> inputStream,
Sink<InputT> sink,
TypeInformation<OutputT> outputType,
String name,
int parallelism,
CustomSinkOperatorUidHashes customSinkOperatorUidHashes) |
Modifier and Type | Method and Description |
---|---|
ChainingStrategy |
getChainingStrategy() |
List<Transformation<?>> |
getInputs()
Returns the
transformations that are the immediate predecessors of the
current transformation in the transformation graph. |
DataStream<InputT> |
getInputStream() |
Sink<InputT> |
getSink() |
CustomSinkOperatorUidHashes |
getSinkOperatorsUidHashes() |
List<Transformation<?>> |
getTransitivePredecessors()
Returns all transitive predecessor
Transformation s of this Transformation . |
void |
setChainingStrategy(ChainingStrategy strategy)
Sets the chaining strategy of this
Transformation . |
declareManagedMemoryUseCaseAtOperatorScope, declareManagedMemoryUseCaseAtSlotScope, equals, getBufferTimeout, getCoLocationGroupKey, getDescription, getId, getManagedMemoryOperatorScopeUseCaseWeights, getManagedMemorySlotScopeUseCases, getMaxParallelism, getMinResources, getName, getNewNodeId, getOutputType, getParallelism, getPreferredResources, getSlotSharingGroup, getUid, getUserProvidedNodeHash, hashCode, setBufferTimeout, setCoLocationGroupKey, setDescription, setMaxParallelism, setName, setOutputType, setParallelism, setResources, setSlotSharingGroup, setSlotSharingGroup, setUid, setUidHash, toString, updateManagedMemoryStateBackendUseCase
public SinkTransformation(DataStream<InputT> inputStream, Sink<InputT> sink, TypeInformation<OutputT> outputType, String name, int parallelism, CustomSinkOperatorUidHashes customSinkOperatorUidHashes)
public void setChainingStrategy(ChainingStrategy strategy)
PhysicalTransformation
Transformation
.setChainingStrategy
in class PhysicalTransformation<OutputT>
public List<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<OutputT>
public List<Transformation<?>> getInputs()
Transformation
transformations
that are the immediate predecessors of the
current transformation in the transformation graph.getInputs
in class Transformation<OutputT>
@Nullable public ChainingStrategy getChainingStrategy()
public DataStream<InputT> getInputStream()
public CustomSinkOperatorUidHashes getSinkOperatorsUidHashes()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.