public class ExecNodeUtil extends Object
ExecNode
to Transformation
.Constructor and Description |
---|
ExecNodeUtil() |
Modifier and Type | Method and Description |
---|---|
static <I,O> OneInputTransformation<I,O> |
createOneInputTransformation(Transformation<I> input,
String name,
String desc,
StreamOperator<O> operator,
TypeInformation<O> outputType,
int parallelism,
boolean parallelismConfigured)
Create a
OneInputTransformation . |
static <I,O> OneInputTransformation<I,O> |
createOneInputTransformation(Transformation<I> input,
String name,
String desc,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism,
boolean parallelismConfigured)
Create a
OneInputTransformation . |
static <I,O> OneInputTransformation<I,O> |
createOneInputTransformation(Transformation<I> input,
String name,
String desc,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes,
boolean parallelismConfigured)
Create a
OneInputTransformation with memoryBytes. |
static <I,O> OneInputTransformation<I,O> |
createOneInputTransformation(Transformation<I> input,
TransformationMetadata transformationMeta,
StreamOperator<O> operator,
TypeInformation<O> outputType,
int parallelism,
boolean parallelismConfigured)
Create a
OneInputTransformation . |
static <I,O> OneInputTransformation<I,O> |
createOneInputTransformation(Transformation<I> input,
TransformationMetadata transformationMeta,
StreamOperator<O> operator,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes,
boolean parallelismConfigured)
Create a
OneInputTransformation with memoryBytes. |
static <I,O> OneInputTransformation<I,O> |
createOneInputTransformation(Transformation<I> input,
TransformationMetadata transformationMeta,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism,
boolean parallelismConfigured)
Create a
OneInputTransformation . |
static <I,O> OneInputTransformation<I,O> |
createOneInputTransformation(Transformation<I> input,
TransformationMetadata transformationMeta,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes,
boolean parallelismConfigured)
Create a
OneInputTransformation with memoryBytes. |
static <I1,I2,O> TwoInputTransformation<I1,I2,O> |
createTwoInputTransformation(Transformation<I1> input1,
Transformation<I2> input2,
String name,
String desc,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes,
boolean parallelismConfigured)
Create a
TwoInputTransformation with memoryBytes. |
static <I1,I2,O> TwoInputTransformation<I1,I2,O> |
createTwoInputTransformation(Transformation<I1> input1,
Transformation<I2> input2,
TransformationMetadata transformationMeta,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes)
Create a
TwoInputTransformation with memoryBytes. |
static <I1,I2,O> TwoInputTransformation<I1,I2,O> |
createTwoInputTransformation(Transformation<I1> input1,
Transformation<I2> input2,
TransformationMetadata transformationMeta,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes,
boolean parallelismConfigured) |
static <IN1,IN2,O> |
createTwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
String name,
String desc,
TwoInputStreamOperator<IN1,IN2,O> operator,
TypeInformation<O> outputType,
int parallelism)
Create a
TwoInputTransformation with memoryBytes. |
static <IN1,IN2,O> |
createTwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
String name,
String desc,
TwoInputStreamOperator<IN1,IN2,O> operator,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes)
Create a
TwoInputTransformation with memoryBytes. |
static <IN1,IN2,O> |
createTwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
TransformationMetadata transformationMeta,
TwoInputStreamOperator<IN1,IN2,O> operator,
TypeInformation<O> outputType,
int parallelism,
boolean parallelismConfigured)
Create a
TwoInputTransformation with memoryBytes. |
static <IN1,IN2,O> |
createTwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
TransformationMetadata transformationMeta,
TwoInputStreamOperator<IN1,IN2,O> operator,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes)
Create a
TwoInputTransformation with memoryBytes. |
static <IN1,IN2,O> |
createTwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
TransformationMetadata transformationMeta,
TwoInputStreamOperator<IN1,IN2,O> operator,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes,
boolean parallelismConfigured) |
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 <I,O> OneInputTransformation<I,O> createOneInputTransformation(Transformation<I> input, TransformationMetadata transformationMeta, StreamOperator<O> operator, TypeInformation<O> outputType, int parallelism, boolean parallelismConfigured)
OneInputTransformation
.public static <I,O> OneInputTransformation<I,O> createOneInputTransformation(Transformation<I> input, String name, String desc, StreamOperator<O> operator, TypeInformation<O> outputType, int parallelism, boolean parallelismConfigured)
OneInputTransformation
.public static <I,O> OneInputTransformation<I,O> createOneInputTransformation(Transformation<I> input, TransformationMetadata transformationMeta, StreamOperator<O> operator, TypeInformation<O> outputType, int parallelism, long memoryBytes, boolean parallelismConfigured)
OneInputTransformation
with memoryBytes.public static <I,O> OneInputTransformation<I,O> createOneInputTransformation(Transformation<I> input, TransformationMetadata transformationMeta, StreamOperatorFactory<O> operatorFactory, TypeInformation<O> outputType, int parallelism, boolean parallelismConfigured)
OneInputTransformation
.public static <I,O> OneInputTransformation<I,O> createOneInputTransformation(Transformation<I> input, String name, String desc, StreamOperatorFactory<O> operatorFactory, TypeInformation<O> outputType, int parallelism, boolean parallelismConfigured)
OneInputTransformation
.public static <I,O> OneInputTransformation<I,O> createOneInputTransformation(Transformation<I> input, String name, String desc, StreamOperatorFactory<O> operatorFactory, TypeInformation<O> outputType, int parallelism, long memoryBytes, boolean parallelismConfigured)
OneInputTransformation
with memoryBytes.public static <I,O> OneInputTransformation<I,O> createOneInputTransformation(Transformation<I> input, TransformationMetadata transformationMeta, StreamOperatorFactory<O> operatorFactory, TypeInformation<O> outputType, int parallelism, long memoryBytes, boolean parallelismConfigured)
OneInputTransformation
with memoryBytes.public static <IN1,IN2,O> TwoInputTransformation<IN1,IN2,O> createTwoInputTransformation(Transformation<IN1> input1, Transformation<IN2> input2, TransformationMetadata transformationMeta, TwoInputStreamOperator<IN1,IN2,O> operator, TypeInformation<O> outputType, int parallelism, boolean parallelismConfigured)
TwoInputTransformation
with memoryBytes.public static <IN1,IN2,O> TwoInputTransformation<IN1,IN2,O> createTwoInputTransformation(Transformation<IN1> input1, Transformation<IN2> input2, String name, String desc, TwoInputStreamOperator<IN1,IN2,O> operator, TypeInformation<O> outputType, int parallelism)
TwoInputTransformation
with memoryBytes.public static <IN1,IN2,O> TwoInputTransformation<IN1,IN2,O> createTwoInputTransformation(Transformation<IN1> input1, Transformation<IN2> input2, TransformationMetadata transformationMeta, TwoInputStreamOperator<IN1,IN2,O> operator, TypeInformation<O> outputType, int parallelism, long memoryBytes)
TwoInputTransformation
with memoryBytes.public static <IN1,IN2,O> TwoInputTransformation<IN1,IN2,O> createTwoInputTransformation(Transformation<IN1> input1, Transformation<IN2> input2, TransformationMetadata transformationMeta, TwoInputStreamOperator<IN1,IN2,O> operator, TypeInformation<O> outputType, int parallelism, long memoryBytes, boolean parallelismConfigured)
public static <IN1,IN2,O> TwoInputTransformation<IN1,IN2,O> createTwoInputTransformation(Transformation<IN1> input1, Transformation<IN2> input2, String name, String desc, TwoInputStreamOperator<IN1,IN2,O> operator, TypeInformation<O> outputType, int parallelism, long memoryBytes)
TwoInputTransformation
with memoryBytes.public static <I1,I2,O> TwoInputTransformation<I1,I2,O> createTwoInputTransformation(Transformation<I1> input1, Transformation<I2> input2, TransformationMetadata transformationMeta, StreamOperatorFactory<O> operatorFactory, TypeInformation<O> outputType, int parallelism, long memoryBytes)
TwoInputTransformation
with memoryBytes.public static <I1,I2,O> TwoInputTransformation<I1,I2,O> createTwoInputTransformation(Transformation<I1> input1, Transformation<I2> input2, TransformationMetadata transformationMeta, StreamOperatorFactory<O> operatorFactory, TypeInformation<O> outputType, int parallelism, long memoryBytes, boolean parallelismConfigured)
public static <I1,I2,O> TwoInputTransformation<I1,I2,O> createTwoInputTransformation(Transformation<I1> input1, Transformation<I2> input2, String name, String desc, StreamOperatorFactory<O> operatorFactory, TypeInformation<O> outputType, int parallelism, long memoryBytes, boolean parallelismConfigured)
TwoInputTransformation
with memoryBytes.public static String getMultipleInputDescription(ExecNode<?> rootNode, List<ExecNode<?>> inputNodes, List<InputProperty> inputProperties)
public static void makeLegacySourceTransformationsBounded(Transformation<?> transformation)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.