@Internal public class MultipleInputTransformation<OUT> extends AbstractMultipleInputTransformation<OUT>
AbstractMultipleInputTransformation
implementation for non-keyed streams.inputs, operatorFactory
bufferTimeout, description, id, name, outputType, typeUsed, UPPER_BOUND_MAX_PARALLELISM
Constructor and Description |
---|
MultipleInputTransformation(String name,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<OUT> outputType,
int parallelism) |
MultipleInputTransformation(String name,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<OUT> outputType,
int parallelism,
boolean parallelismConfigured) |
Modifier and Type | Method and Description |
---|---|
MultipleInputTransformation<OUT> |
addInput(Transformation<?> input) |
getInputs, getInputTypes, getOperatorFactory, getTransitivePredecessors, setChainingStrategy
isSupportsConcurrentExecutionAttempts, setSupportsConcurrentExecutionAttempts
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, toStringWithoutId, updateManagedMemoryStateBackendUseCase
public MultipleInputTransformation(String name, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<OUT> outputType, int parallelism)
public MultipleInputTransformation(String name, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<OUT> outputType, int parallelism, boolean parallelismConfigured)
public MultipleInputTransformation<OUT> addInput(Transformation<?> input)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.