IN
- The input and output type of the transformation.@Internal public class TimestampsAndWatermarksTransformation<IN> extends PhysicalTransformation<IN>
bufferTimeout, id, idCounter, name, outputType, typeUsed, UPPER_BOUND_MAX_PARALLELISM
Constructor and Description |
---|
TimestampsAndWatermarksTransformation(String name,
int parallelism,
Transformation<IN> input,
WatermarkStrategy<IN> watermarkStrategy)
Creates a new
Transformation with the given name, output type and parallelism. |
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. |
TypeInformation<IN> |
getInputType()
Returns the
TypeInformation for the elements of the input. |
List<Transformation<?>> |
getTransitivePredecessors()
Returns all transitive predecessor
Transformation s of this Transformation . |
WatermarkStrategy<IN> |
getWatermarkStrategy()
Returns the
WatermarkStrategy to use. |
void |
setChainingStrategy(ChainingStrategy chainingStrategy)
Sets the chaining strategy of this
Transformation . |
declareManagedMemoryUseCaseAtOperatorScope, declareManagedMemoryUseCaseAtSlotScope, equals, getBufferTimeout, getCoLocationGroupKey, getId, getManagedMemoryOperatorScopeUseCaseWeights, getManagedMemorySlotScopeUseCases, getMaxParallelism, getMinResources, getName, getNewNodeId, getOutputType, getParallelism, getPreferredResources, getSlotSharingGroup, getUid, getUserProvidedNodeHash, hashCode, setBufferTimeout, setCoLocationGroupKey, setMaxParallelism, setName, setOutputType, setParallelism, setResources, setSlotSharingGroup, setUid, setUidHash, toString, updateManagedMemoryStateBackendUseCase
public TimestampsAndWatermarksTransformation(String name, int parallelism, Transformation<IN> input, WatermarkStrategy<IN> watermarkStrategy)
Transformation
with the given name, output type and parallelism.name
- The name of the Transformation
, this will be shown in Visualizations and
the Logparallelism
- The parallelism of this Transformation
input
- The input transformation of this Transformation
watermarkStrategy
- The WatermarkStrategy
to usepublic TypeInformation<IN> getInputType()
TypeInformation
for the elements of the input.public WatermarkStrategy<IN> getWatermarkStrategy()
WatermarkStrategy
to use.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<IN>
public List<Transformation<?>> getInputs()
Transformation
transformations
that are the immediate predecessors of the
current transformation in the transformation graph.getInputs
in class Transformation<IN>
public ChainingStrategy getChainingStrategy()
public void setChainingStrategy(ChainingStrategy chainingStrategy)
PhysicalTransformation
Transformation
.setChainingStrategy
in class PhysicalTransformation<IN>
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.