T
- The type of the elements in the cache intermediate result.@Internal public class CacheTransformation<T> extends Transformation<T>
CacheTransformation
represents the intermediate result of the
upper stream should be cached when it is computed at the first time. And it consumes the cached
intermediate result in later jobs. In stream mode, it has no affect.bufferTimeout, description, id, name, outputType, typeUsed, UPPER_BOUND_MAX_PARALLELISM
Constructor and Description |
---|
CacheTransformation(Transformation<T> transformationToCache,
String name)
Creates a new
Transformation with the given name, output type and parallelism. |
Modifier and Type | Method and Description |
---|---|
AbstractID |
getDatasetId() |
List<Transformation<?>> |
getInputs()
Returns the
transformations that are the immediate predecessors of the
current transformation in the transformation graph. |
Transformation<T> |
getTransformationToCache() |
List<Transformation<?>> |
getTransitivePredecessors()
Returns all transitive predecessor
Transformation s of this Transformation . |
boolean |
isCached() |
void |
setCached(boolean cached) |
declareManagedMemoryUseCaseAtOperatorScope, declareManagedMemoryUseCaseAtSlotScope, equals, getBufferTimeout, getCoLocationGroupKey, getDescription, getId, getManagedMemoryOperatorScopeUseCaseWeights, getManagedMemorySlotScopeUseCases, getMaxParallelism, getMinResources, getName, getNewNodeId, getOutputType, getParallelism, getPreferredResources, getSlotSharingGroup, getUid, getUserProvidedNodeHash, hashCode, isParallelismConfigured, setBufferTimeout, setCoLocationGroupKey, setDescription, setMaxParallelism, setName, setOutputType, setParallelism, setParallelism, setResources, setSlotSharingGroup, setSlotSharingGroup, setUid, setUidHash, toString, updateManagedMemoryStateBackendUseCase
public CacheTransformation(Transformation<T> transformationToCache, String name)
Transformation
with the given name, output type and parallelism.name
- The name of the Transformation
, this will be shown in Visualizations and
the Logpublic 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<T>
public List<Transformation<?>> getInputs()
Transformation
transformations
that are the immediate predecessors of the
current transformation in the transformation graph.getInputs
in class Transformation<T>
public AbstractID getDatasetId()
public Transformation<T> getTransformationToCache()
public void setCached(boolean cached)
public boolean isCached()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.