public class PythonPlanBinder extends Object
Modifier and Type | Class and Description |
---|---|
protected static class |
PythonPlanBinder.Operation
This enum contains the identifiers for all supported DataSet operations.
|
Modifier and Type | Field and Description |
---|---|
static String |
ARGUMENT_PYTHON_2 |
static String |
ARGUMENT_PYTHON_3 |
static StringBuilder |
arguments |
ExecutionEnvironment |
env |
static String |
FLINK_PYTHON_DC_ID |
static String |
FLINK_PYTHON_FILE_PATH |
static String |
FLINK_PYTHON_PLAN_NAME |
static String |
FLINK_PYTHON2_BINARY_KEY |
static String |
FLINK_PYTHON2_BINARY_PATH |
static String |
FLINK_PYTHON3_BINARY_KEY |
static String |
FLINK_PYTHON3_BINARY_PATH |
static String |
FLINK_TMP_DATA_DIR |
static int |
MAPPED_FILE_SIZE |
static String |
PLANBINDER_CONFIG_BCVAR_COUNT |
static String |
PLANBINDER_CONFIG_BCVAR_NAME_PREFIX |
static boolean |
usePython3 |
Constructor and Description |
---|
PythonPlanBinder() |
Modifier and Type | Method and Description |
---|---|
static void |
main(String[] args)
Entry point for the execution of a python plan.
|
public static final String ARGUMENT_PYTHON_2
public static final String ARGUMENT_PYTHON_3
public static final String FLINK_PYTHON_DC_ID
public static final String FLINK_PYTHON_PLAN_NAME
public static final String FLINK_PYTHON2_BINARY_KEY
public static final String FLINK_PYTHON3_BINARY_KEY
public static final String PLANBINDER_CONFIG_BCVAR_COUNT
public static final String PLANBINDER_CONFIG_BCVAR_NAME_PREFIX
public static String FLINK_PYTHON2_BINARY_PATH
public static String FLINK_PYTHON3_BINARY_PATH
public static final String FLINK_PYTHON_FILE_PATH
public static StringBuilder arguments
public static boolean usePython3
public static final String FLINK_TMP_DATA_DIR
public ExecutionEnvironment env
public static final int MAPPED_FILE_SIZE
public PythonPlanBinder() throws IOException
IOException
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.