@Internal public class KeyedMultipleInputTransformation<OUT> extends AbstractMultipleInputTransformation<OUT>
AbstractMultipleInputTransformation
implementation for keyed streams.Modifier and Type | Field and Description |
---|---|
protected TypeInformation<?> |
stateKeyType |
inputs, operatorFactory
bufferTimeout, description, id, idCounter, name, outputType, typeUsed, UPPER_BOUND_MAX_PARALLELISM
Constructor and Description |
---|
KeyedMultipleInputTransformation(String name,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<OUT> outputType,
int parallelism,
TypeInformation<?> stateKeyType) |
Modifier and Type | Method and Description |
---|---|
KeyedMultipleInputTransformation<OUT> |
addInput(Transformation<?> input,
KeySelector<?,?> keySelector) |
List<KeySelector<?,?>> |
getStateKeySelectors() |
TypeInformation<?> |
getStateKeyType() |
getInputs, getInputTypes, getOperatorFactory, getTransitivePredecessors, setChainingStrategy
declareManagedMemoryUseCaseAtOperatorScope, declareManagedMemoryUseCaseAtSlotScope, equals, getBufferTimeout, getCoLocationGroupKey, getDescription, getId, getManagedMemoryOperatorScopeUseCaseWeights, getManagedMemorySlotScopeUseCases, getMaxParallelism, getMinResources, getName, getNewNodeId, getOutputType, getParallelism, getPreferredResources, getSlotSharingGroup, getUid, getUserProvidedNodeHash, hashCode, setBufferTimeout, setCoLocationGroupKey, setDescription, setMaxParallelism, setName, setOutputType, setParallelism, setResources, setSlotSharingGroup, setSlotSharingGroup, setUid, setUidHash, toString, updateManagedMemoryStateBackendUseCase
protected final TypeInformation<?> stateKeyType
public KeyedMultipleInputTransformation(String name, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<OUT> outputType, int parallelism, TypeInformation<?> stateKeyType)
public KeyedMultipleInputTransformation<OUT> addInput(Transformation<?> input, KeySelector<?,?> keySelector)
public TypeInformation<?> getStateKeyType()
public List<KeySelector<?,?>> getStateKeySelectors()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.