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)
