public class ExecNodeUtil extends Object
ExecNode
to Transformation
.Constructor and Description |
---|
ExecNodeUtil() |
Modifier and Type | Method and Description |
---|---|
static <T> OneInputTransformation<T,T> |
createOneInputTransformation(Transformation<T> input,
String name,
StreamOperatorFactory<T> operatorFactory,
TypeInformation<T> outputType,
int parallelism,
long memoryBytes)
Create a
OneInputTransformation with memoryBytes. |
static <T> TwoInputTransformation<T,T,T> |
createTwoInputTransformation(Transformation<T> input1,
Transformation<T> input2,
String name,
StreamOperatorFactory<T> operatorFactory,
TypeInformation<T> outputType,
int parallelism,
long memoryBytes)
Create a
TwoInputTransformation with memoryBytes. |
static String |
getMultipleInputDescription(ExecNode<?> rootNode,
List<ExecNode<?>> inputNodes,
List<InputProperty> inputProperties)
Return description for multiple input node.
|
static void |
makeLegacySourceTransformationsBounded(Transformation<?> transformation)
The planner might have more information than expressed in legacy source transformations.
|
static <T> void |
setManagedMemoryWeight(Transformation<T> transformation,
long memoryBytes)
Sets {Transformation#declareManagedMemoryUseCaseAtOperatorScope(ManagedMemoryUseCase, int)}
using the given bytes for
ManagedMemoryUseCase.OPERATOR . |
public static <T> void setManagedMemoryWeight(Transformation<T> transformation, long memoryBytes)
ManagedMemoryUseCase.OPERATOR
.public static <T> OneInputTransformation<T,T> createOneInputTransformation(Transformation<T> input, String name, StreamOperatorFactory<T> operatorFactory, TypeInformation<T> outputType, int parallelism, long memoryBytes)
OneInputTransformation
with memoryBytes.public static <T> TwoInputTransformation<T,T,T> createTwoInputTransformation(Transformation<T> input1, Transformation<T> input2, String name, StreamOperatorFactory<T> operatorFactory, TypeInformation<T> outputType, int parallelism, long memoryBytes)
TwoInputTransformation
with memoryBytes.public static String getMultipleInputDescription(ExecNode<?> rootNode, List<ExecNode<?>> inputNodes, List<InputProperty> inputProperties)
public static void makeLegacySourceTransformationsBounded(Transformation<?> transformation)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.