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, description, id, 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) |
protected |
AbstractBroadcastStateTransformation(String name,
Transformation<IN1> regularInput,
Transformation<IN2> broadcastInput,
List<MapStateDescriptor<?,?>> broadcastStateDescriptors,
TypeInformation<OUT> outTypeInfo,
int parallelism,
boolean parallelismConfigured) |
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() |
protected List<Transformation<?>> |
getTransitivePredecessorsInternal()
Returns all transitive predecessor
Transformation s of this Transformation . |
void |
setChainingStrategy(ChainingStrategy chainingStrategy)
Sets the chaining strategy of this
Transformation . |
isSupportsConcurrentExecutionAttempts, setSupportsConcurrentExecutionAttempts
declareManagedMemoryUseCaseAtOperatorScope, declareManagedMemoryUseCaseAtSlotScope, equals, getBufferTimeout, getCoLocationGroupKey, getDescription, getId, getManagedMemoryOperatorScopeUseCaseWeights, getManagedMemorySlotScopeUseCases, getMaxParallelism, getMinResources, getName, getNewNodeId, getOutputType, getParallelism, getPreferredResources, getSlotSharingGroup, getTransitivePredecessors, getUid, getUserProvidedNodeHash, hashCode, isParallelismConfigured, setBufferTimeout, setCoLocationGroupKey, setDescription, setMaxParallelism, setName, setOutputType, setParallelism, setParallelism, setResources, setSlotSharingGroup, setSlotSharingGroup, setUid, setUidHash, toString, updateManagedMemoryStateBackendUseCase
protected AbstractBroadcastStateTransformation(String name, Transformation<IN1> regularInput, Transformation<IN2> broadcastInput, List<MapStateDescriptor<?,?>> broadcastStateDescriptors, TypeInformation<OUT> outTypeInfo, int parallelism)
protected AbstractBroadcastStateTransformation(String name, Transformation<IN1> regularInput, Transformation<IN2> broadcastInput, List<MapStateDescriptor<?,?>> broadcastStateDescriptors, TypeInformation<OUT> outTypeInfo, int parallelism, boolean parallelismConfigured)
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>
protected List<Transformation<?>> getTransitivePredecessorsInternal()
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.getTransitivePredecessorsInternal
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–2024 The Apache Software Foundation. All rights reserved.