Package | Description |
---|---|
org.apache.flink.client.python |
Modifier and Type | Method and Description |
---|---|
static PythonDriverEnvUtils.PythonEnvironment |
PythonDriverEnvUtils.preparePythonEnvironment(org.apache.flink.client.python.PythonDriverOptions pythonDriverOptions,
String tmpDir)
Prepares PythonEnvironment to start python process.
|
Modifier and Type | Method and Description |
---|---|
static Process |
PythonDriverEnvUtils.startPythonProcess(PythonDriverEnvUtils.PythonEnvironment pythonEnv,
List<String> commands)
Starts python process.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.