public class PythonConfigUtil extends Object
StreamExecutionEnvironment
configuration and merged configuration
with environment settings.Modifier and Type | Field and Description |
---|---|
static String |
KEYED_STREAM_VALUE_OPERATOR_NAME |
static String |
STREAM_KEY_BY_MAP_OPERATOR_NAME |
static String |
STREAM_PARTITION_CUSTOM_MAP_OPERATOR_NAME |
Constructor and Description |
---|
PythonConfigUtil() |
Modifier and Type | Method and Description |
---|---|
static void |
configPythonOperator(StreamExecutionEnvironment env) |
static Configuration |
getEnvConfigWithDependencies(StreamExecutionEnvironment env)
A static method to get the
StreamExecutionEnvironment configuration merged with
python dependency management configurations. |
static Configuration |
getEnvironmentConfig(StreamExecutionEnvironment env)
Get the private field
StreamExecutionEnvironment#configuration by reflection
recursively. |
static Configuration |
getMergedConfig(ExecutionEnvironment env,
TableConfig tableConfig) |
static Configuration |
getMergedConfig(StreamExecutionEnvironment env,
TableConfig tableConfig) |
static boolean |
isPythonDataStreamOperator(Transformation<?> transform) |
static boolean |
isPythonOperator(Transformation<?> transform) |
static void |
setPartitionCustomOperatorNumPartitions(List<Transformation<?>> transformations) |
public static final String KEYED_STREAM_VALUE_OPERATOR_NAME
public static final String STREAM_KEY_BY_MAP_OPERATOR_NAME
public static final String STREAM_PARTITION_CUSTOM_MAP_OPERATOR_NAME
public static Configuration getEnvConfigWithDependencies(StreamExecutionEnvironment env) throws InvocationTargetException, IllegalAccessException, NoSuchFieldException
StreamExecutionEnvironment
configuration merged with
python dependency management configurations.public static Configuration getEnvironmentConfig(StreamExecutionEnvironment env) throws InvocationTargetException, IllegalAccessException, NoSuchFieldException
StreamExecutionEnvironment#configuration
by reflection
recursively. Then access the field to get the configuration of the given
StreamExecutionEnvironment.public static void configPythonOperator(StreamExecutionEnvironment env) throws IllegalAccessException, InvocationTargetException, NoSuchFieldException
public static Configuration getMergedConfig(StreamExecutionEnvironment env, TableConfig tableConfig)
public static Configuration getMergedConfig(ExecutionEnvironment env, TableConfig tableConfig)
public static boolean isPythonOperator(Transformation<?> transform)
public static boolean isPythonDataStreamOperator(Transformation<?> transform)
public static void setPartitionCustomOperatorNumPartitions(List<Transformation<?>> transformations)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.