godfrey he created FLINK-13088:
----------------------------------
Summary: Supports execute DAG plan
Key: FLINK-13088
URL: https://issues.apache.org/jira/browse/FLINK-13088
Project: Flink
Issue Type: New Feature
Components: Table SQL / Planner
Reporter: godfrey he
Assignee: godfrey he
in [FLINK-13081|https://issues.apache.org/jira/browse/FLINK-13081], {{explain}}
method will be introduced to support explain multiple-sinks plan, this issue
aims to introduce {{execute}} method into {{TableEnvironment}} to trigger the
program execution. and in blink planner, queries will not be optimized
immediately in {{insertInto}}/{{sqlUpdate}} methods, and will be optimized
together in this method.
{code:java}
// Triggers the program execution
JobExecutionResult execute(String jobName) throws Exception;
{code}
there are two concerns about this method:
1. which {{execute}} methods ({{TableEnvironment#execute}} or
{{StreamExecutionEnvironment#execute}}) users should use?
2. how to make sure users only use {{TableEnvironment#execute}} method if
their code only depends on planner module instead of bridge module？
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
