leonardBang commented on a change in pull request #16380:
URL: https://github.com/apache/flink/pull/16380#discussion_r664311383
##########
File path: docs/content/docs/dev/table/common.md
##########
@@ -837,34 +837,21 @@ The result of the above exmaple is
== Abstract Syntax Tree ==
LogicalUnion(all=[true])
- LogicalFilter(condition=[LIKE($1, _UTF-16LE'F%')])
- FlinkLogicalDataStreamScan(id=[1], fields=[count, word])
- FlinkLogicalDataStreamScan(id=[2], fields=[count, word])
-
-== Optimized Logical Plan ==
-DataStreamUnion(all=[true], union all=[count, word])
- DataStreamCalc(select=[count, word], where=[LIKE(word, _UTF-16LE'F%')])
- DataStreamScan(id=[1], fields=[count, word])
- DataStreamScan(id=[2], fields=[count, word])
-
-== Physical Execution Plan ==
-Stage 1 : Data Source
- content : collect elements with CollectionInputFormat
-
-Stage 2 : Data Source
- content : collect elements with CollectionInputFormat
-
- Stage 3 : Operator
- content : from: (count, word)
- ship_strategy : REBALANCE
-
- Stage 4 : Operator
- content : where: (LIKE(word, _UTF-16LE'F%')), select:
(count, word)
- ship_strategy : FORWARD
-
- Stage 5 : Operator
- content : from: (count, word)
- ship_strategy : REBALANCE
Review comment:
Could you use `table.explain(ExplainDetail.JSON_EXECUTION_PLAN)` in
above **java**/**scala**/**python** codes and replace the explain output?
Because the outdated `== Physical Execution Plan ==` now is represented in
json format, the new explain out should like:
```
== Abstract Syntax Tree ==
LogicalUnion(all=[true])
:- LogicalFilter(condition=[LIKE($1, _UTF-16LE'F%')])
: +- LogicalTableScan(table=[[Unregistered_DataStream_3]])
+- LogicalTableScan(table=[[Unregistered_DataStream_4]])
== Optimized Physical Plan ==
Union(all=[true], union=[count, word])
:- Calc(select=[count, word], where=[LIKE(word, _UTF-16LE'F%')])
: +- DataStreamScan(table=[[Unregistered_DataStream_3]], fields=[count,
word])
+- DataStreamScan(table=[[Unregistered_DataStream_4]], fields=[count, word])
== Optimized Execution Plan ==
Union(all=[true], union=[count, word])
:- Calc(select=[count, word], where=[LIKE(word, _UTF-16LE'F%')])
: +- DataStreamScan(table=[[Unregistered_DataStream_3]], fields=[count,
word])
+- DataStreamScan(table=[[Unregistered_DataStream_4]], fields=[count, word])
== Physical Execution Plan ==
{
"nodes" : [ {
"id" : 3,
"type" : "Source: Collection Source",
"pact" : "Data Source",
"contents" : "Source: Collection Source",
"parallelism" : 1
}, {
"id" : 4,
"type" : "Source: Collection Source",
"pact" : "Data Source",
"contents" : "Source: Collection Source",
"parallelism" : 1
}, {
"id" : 5,
"type" : "SourceConversion(table=[Unregistered_DataStream_3],
fields=[count, word])",
"pact" : "Operator",
"contents" : "SourceConversion(table=[Unregistered_DataStream_3],
fields=[count, word])",
"parallelism" : 1,
"predecessors" : [ {
"id" : 3,
"ship_strategy" : "FORWARD",
"side" : "second"
} ]
}, {
"id" : 6,
"type" : "Calc(select=[count, word], where=[LIKE(word, _UTF-16LE'F%')])",
"pact" : "Operator",
"contents" : "Calc(select=[count, word], where=[LIKE(word,
_UTF-16LE'F%')])",
"parallelism" : 1,
"predecessors" : [ {
"id" : 5,
"ship_strategy" : "FORWARD",
"side" : "second"
} ]
}, {
"id" : 7,
"type" : "SourceConversion(table=[Unregistered_DataStream_4],
fields=[count, word])",
"pact" : "Operator",
"contents" : "SourceConversion(table=[Unregistered_DataStream_4],
fields=[count, word])",
"parallelism" : 1,
"predecessors" : [ {
"id" : 4,
"ship_strategy" : "FORWARD",
"side" : "second"
} ]
} ]
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
