[jira] [Created] (FLINK-21091) Support ExecNode json serialization/deserialization

["godfrey he (Jira)" <ji...@apache.org>]

godfrey he created FLINK-21091:
----------------------------------

             Summary: 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


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 operation:
{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)