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