[
https://issues.apache.org/jira/browse/FLINK-21091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-21091:
----------------------------------
Assignee: godfrey he
> Support ExecNode json serialization/deserialization
> ---------------------------------------------------
>
> Key: FLINK-21091
> URL: https://issues.apache.org/jira/browse/FLINK-21091
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / Planner
> Reporter: godfrey he
> Assignee: godfrey he
> Priority: Major
> Fix For: 1.14.0
>
>
> Since FLINK-20435 is finished, an ExecNode graph can be serialized to a json
> plan or a json plan can deserialized to an ExecNode graph. Only Blink planner
> introduce ExecNode, so legacy planner does not supports this feature.
> We will introduce the following methods to support json plan operations:
> {code:java}
> // Get the json plan for the given statement.
> String getJsonPlan(String stmt);
> // Returns the execution plan for the given json plan.
> String explainJsonPlan(String jsonPlan, ExplainDetail... extraDetails);
> // Execute the given json plan, and return the execution result.
> TableResult executeJsonPlan(String jsonPlan);
> {code}
> Currently, these methods are *experimental* features, so we introduce them
> into TableEnvironmentInternal as first step.
> This is an umbrella issue, we will create more related sub-tasks, including:
> 1. introduce the above methods
> 2. support json serialization/deserialization for all StreamExecNodes
> 3. introduce complete testing to verify ExecNode
> serialization/deserialization for different queries
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
