PythonStreamExecutionEnvironment |
PythonEnvironmentFactory.create_local_execution_environment(Configuration config)
|
PythonStreamExecutionEnvironment |
PythonEnvironmentFactory.create_local_execution_environment(int parallelism,
Configuration config)
|
PythonStreamExecutionEnvironment |
PythonEnvironmentFactory.create_remote_execution_environment(String host,
int port,
Configuration config,
String... jar_files)
|
PythonStreamExecutionEnvironment |
PythonEnvironmentFactory.create_remote_execution_environment(String host,
int port,
int parallelism,
String... jar_files)
|
PythonStreamExecutionEnvironment |
PythonEnvironmentFactory.create_remote_execution_environment(String host,
int port,
String... jar_files)
|
PythonStreamExecutionEnvironment |
PythonStreamExecutionEnvironment.enable_checkpointing(long interval)
|
PythonStreamExecutionEnvironment |
PythonStreamExecutionEnvironment.enable_checkpointing(long interval,
CheckpointingMode mode)
|
PythonStreamExecutionEnvironment |
PythonEnvironmentFactory.get_execution_environment()
|
PythonStreamExecutionEnvironment |
PythonStreamExecutionEnvironment.set_parallelism(int parallelism)
|