public class PythonConfigUtil extends Object
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 List<MapStateDescriptor<ByteArrayWrapper,byte[]>> |
convertStateNamesToStateDescriptors(String[] names) |
static SingleOutputStreamOperator<?> |
createSingleOutputStreamOperator(StreamExecutionEnvironment env,
Transformation<?> transformation) |
static Configuration |
extractPythonConfiguration(ReadableConfig config)
Extract the configurations which is used in the Python operators.
|
static Configuration |
getEnvironmentConfig(StreamExecutionEnvironment env) |
static StreamOperatorFactory<?> |
getOperatorFactory(Transformation<?> transform) |
static boolean |
isPythonDataStreamOperator(Transformation<?> transform) |
static void |
registerPythonBroadcastTransformationTranslator() |
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 getEnvironmentConfig(StreamExecutionEnvironment env)
public static void configPythonOperator(StreamExecutionEnvironment env) throws Exception
Exception
public static Configuration extractPythonConfiguration(ReadableConfig config)
public static StreamOperatorFactory<?> getOperatorFactory(Transformation<?> transform)
public static boolean isPythonDataStreamOperator(Transformation<?> transform)
public static void setPartitionCustomOperatorNumPartitions(List<Transformation<?>> transformations)
public static List<MapStateDescriptor<ByteArrayWrapper,byte[]>> convertStateNamesToStateDescriptors(String[] names)
public static void registerPythonBroadcastTransformationTranslator() throws Exception
Exception
public static SingleOutputStreamOperator<?> createSingleOutputStreamOperator(StreamExecutionEnvironment env, Transformation<?> transformation) throws Exception
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.