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 <T> void |
setManagedMemoryWeight(Transformation<T> transformation,
long memoryBytes)
|
public static <T> void setManagedMemoryWeight(Transformation<T> transformation, long memoryBytes)
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.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.