[
https://issues.apache.org/jira/browse/FLINK-21092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-21092.
------------------------------
Resolution: Fixed
Fixed in 1.13.0: e16e45f29e0c8b7dc771f4acb50e5b3910a751e2
> Introduce getJsonPlan, explainJsonPlan and executeJsonPlan in
> TableEnvironmentInternal
> ---------------------------------------------------------------------------------------
>
> Key: FLINK-21092
> URL: https://issues.apache.org/jira/browse/FLINK-21092
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Planner
> Reporter: godfrey he
> Assignee: godfrey he
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.13.0
>
>
> We will introduce the following methods to support json plan operations in
> TableEnvironmentInternal:
> {code:java}
> /**
> * Get the json plan for the given statement.
> *
> * <p>The statement can only be DML.
> *
> * <p>The json plan is the string json representation of an optimized
> ExecNode plan for the
> * given statement. An ExecNode plan can be serialized to json plan, and
> a json plan can be
> * deserialized to an ExecNode plan.
> */
> @Experimental
> String getJsonPlan(String stmt);
> /**
> * Get the json plan for the given {@link ModifyOperation}s.
> */
> @Experimental
> String getJsonPlan(List<ModifyOperation> operations);
> /**
> * Returns the execution plan for the given json plan.
> */
> @Experimental
> String explainJsonPlan(String jsonPlan, ExplainDetail... extraDetails);
> /**
> * Execute the given json plan, and return the execution result. A SQL
> statement can be
> * converted to json plan through {@link #getJsonPlan(String)}.
> */
> @Experimental
> TableResult executeJsonPlan(String jsonPlan);
> {code}
> and we also introduce getJsonPlan method in StatementSetImpl so that we can
> get the json plan of the all statements and Tables as a batch.
> {code:java}
> /**
> * Get the json plan of the all statements and Tables as a batch.
> */
> @Experimental
> public String getJsonPlan() {
> }
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
