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 |
FLINK_PYTHON_DC_ID |
static String |
FLINK_PYTHON_PLAN_NAME |
static String |
PLAN_ARGUMENTS_KEY |
static String |
PLANBINDER_CONFIG_BCVAR_COUNT |
static String |
PLANBINDER_CONFIG_BCVAR_NAME_PREFIX |
Constructor and Description |
---|
PythonPlanBinder(Configuration globalConfig) |
Modifier and Type | Method and Description |
---|---|
static void |
main(String[] args)
Entry point for the execution of a python plan.
|
public static final String FLINK_PYTHON_DC_ID
public static final String FLINK_PYTHON_PLAN_NAME
public static final String PLANBINDER_CONFIG_BCVAR_COUNT
public static final String PLANBINDER_CONFIG_BCVAR_NAME_PREFIX
public static final String PLAN_ARGUMENTS_KEY
public PythonPlanBinder(Configuration globalConfig)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.