IN1
- The type of the elements in the non-broadcasted input.IN2
- The type of the elements in the broadcasted input.OUT
- The type of the elements that result from this transformation.@Internal public class AbstractBroadcastStateTransformation<IN1,IN2,OUT> extends PhysicalTransformation<OUT>
For more information see the Broadcast State Pattern documentation page.
bufferTimeout, id, idCounter, name, outputType, typeUsed, UPPER_BOUND_MAX_PARALLELISM
Modifier | Constructor and Description |
---|---|
protected |
AbstractBroadcastStateTransformation(String name,
Transformation<IN1> regularInput,
Transformation<IN2> broadcastInput,
List<MapStateDescriptor<?,?>> broadcastStateDescriptors,
TypeInformation<OUT> outTypeInfo,
int parallelism) |
Modifier and Type | Method and Description |
---|---|
Transformation<IN2> |
getBroadcastInput() |
List<MapStateDescriptor<?,?>> |
getBroadcastStateDescriptors() |
ChainingStrategy |
getChainingStrategy() |
List<Transformation<?>> |
getInputs()
Returns the
transformations that are the immediate predecessors of the
current transformation in the transformation graph. |
Transformation<IN1> |
getRegularInput() |
List<Transformation<?>> |
getTransitivePredecessors()
Returns all transitive predecessor
Transformation s of this Transformation . |
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
protected AbstractBroadcastStateTransformation(String name, Transformation<IN1> regularInput, Transformation<IN2> broadcastInput, List<MapStateDescriptor<?,?>> broadcastStateDescriptors, TypeInformation<OUT> outTypeInfo, int parallelism)
public Transformation<IN2> getBroadcastInput()
public Transformation<IN1> getRegularInput()
public List<MapStateDescriptor<?,?>> getBroadcastStateDescriptors()
public ChainingStrategy getChainingStrategy()
public void setChainingStrategy(ChainingStrategy chainingStrategy)
PhysicalTransformation
Transformation
.setChainingStrategy
in class PhysicalTransformation<OUT>
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<OUT>
public List<Transformation<?>> getInputs()
Transformation
transformations
that are the immediate predecessors of the
current transformation in the transformation graph.getInputs
in class Transformation<OUT>
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.