This is an automated email from the ASF dual-hosted git repository.
kurt pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 0d1738b [FLINK-17256][python] Support keyword arguments in the
PyFlink descriptor API
new 59ca355 [FLINK-17267] [table-planner] legacy stream planner supports
explain insert operation
new 2fc82ad [FLINK-17267] [table-planner] legacy batch planner supports
explain insert operation
new 6013a62 [FLINK-17267] [table] TableEnvironment#explainSql supports
EXPLAIN statement
new 1a5fc5f [FLINK-17267] [table] Introduce TableEnvironment#explainSql
api
new 4959ebf [FLINK-17267] [table] Introduce Table#explain api
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
flink-python/pyflink/table/__init__.py | 4 +-
flink-python/pyflink/table/explain_detail.py | 34 +++
flink-python/pyflink/table/table.py | 14 ++
flink-python/pyflink/table/table_environment.py | 19 +-
flink-python/pyflink/table/tests/test_explain.py | 40 +++
.../table/tests/test_table_environment_api.py | 34 ++-
flink-python/pyflink/util/utils.py | 20 ++
.../org/apache/flink/table/api/ExplainDetail.java} | 45 ++--
.../java/org/apache/flink/table/api/Table.java | 10 +
.../apache/flink/table/api/TableEnvironment.java | 15 +-
.../table/api/internal/TableEnvironmentImpl.java | 48 +++-
.../api/internal/TableEnvironmentInternal.java | 14 ++
.../apache/flink/table/api/internal/TableImpl.java | 6 +
.../flink/table/api/internal/TableResultImpl.java | 51 +++-
.../org/apache/flink/table/delegation/Planner.java | 7 +-
.../flink/table/operations/ExplainOperation.java} | 39 ++-
.../org/apache/flink/table/utils/PlannerMock.java | 3 +-
.../operations/SqlToOperationConverter.java | 19 ++
.../table/planner/calcite/FlinkPlannerImpl.scala | 11 +-
.../table/planner/delegation/BatchPlanner.scala | 30 ++-
.../table/planner/delegation/StreamPlanner.scala | 33 ++-
.../explain/testExecuteSqlWithExplainInsert.out | 31 +++
.../explain/testExecuteSqlWithExplainSelect.out | 21 ++
.../resources/explain/testExplainSqlWithInsert.out | 31 +++
.../resources/explain/testExplainSqlWithSelect.out | 21 ++
.../flink/table/api/TableEnvironmentTest.scala | 194 +++++++++++++-
.../flink/table/planner/utils/TableTestBase.scala | 2 +-
.../table/sqlexec/SqlToOperationConverter.java | 19 ++
.../table/api/internal/BatchTableEnvImpl.scala | 230 ++++++++++++++---
.../flink/table/api/internal/TableEnvImpl.scala | 88 ++++++-
.../flink/table/calcite/FlinkPlannerImpl.scala | 11 +-
.../table/calcite/RelTimeIndicatorConverter.scala | 30 +++
.../flink/table/plan/nodes/LogicalSink.scala | 55 ++++
.../org/apache/flink/table/plan/nodes/Sink.scala | 57 +++++
.../table/plan/nodes/dataset/DataSetSink.scala | 57 +++++
.../plan/nodes/datastream/DataStreamSink.scala | 204 +++++++++++++++
.../plan/nodes/logical/FlinkLogicalSink.scala | 73 ++++++
.../flink/table/plan/rules/FlinkRuleSets.scala | 9 +-
.../table/plan/rules/dataSet/DataSetSinkRule.scala | 55 ++++
.../plan/rules/datastream/DataStreamSinkRule.scala | 53 ++++
.../apache/flink/table/planner/StreamPlanner.scala | 280 +++++++--------------
.../flink/table/sinks/DataStreamTableSink.scala | 58 +++++
.../flink/table/api/TableEnvironmentITCase.scala | 17 +-
.../api/batch/BatchTableEnvironmentTest.scala | 201 ++++++++++++++-
.../apache/flink/table/api/batch/ExplainTest.scala | 71 ++++--
.../sql/validation/InsertIntoValidationTest.scala | 8 +
.../validation/InsertIntoValidationTest.scala | 4 +
.../flink/table/api/stream/ExplainTest.scala | 75 ++++--
.../api/stream/StreamTableEnvironmentTest.scala | 206 ++++++++++++++-
.../flink/table/utils/MockTableEnvironment.scala | 4 +-
.../apache/flink/table/utils/TableTestBase.scala | 10 +
.../resources/testExecuteSqlWithExplainInsert0.out | 31 +++
.../resources/testExecuteSqlWithExplainInsert1.out | 36 +++
.../resources/testExecuteSqlWithExplainSelect0.out | 21 ++
.../resources/testExecuteSqlWithExplainSelect1.out | 27 ++
.../scala/resources/testExplainSqlWithInsert0.out | 31 +++
.../scala/resources/testExplainSqlWithInsert1.out | 43 ++++
.../scala/resources/testExplainSqlWithSelect0.out | 21 ++
.../scala/resources/testExplainSqlWithSelect1.out | 27 ++
.../resources/testFromToDataStreamAndSqlUpdate.out | 23 +-
.../src/test/scala/resources/testInsert.out | 29 +++
.../src/test/scala/resources/testInsert1.out | 27 ++
.../test/scala/resources/testMultipleInserts.out | 55 ++++
.../test/scala/resources/testMultipleInserts1.out | 51 ++++
.../resources/testSqlUpdateAndToDataStream.out | 20 +-
65 files changed, 2709 insertions(+), 404 deletions(-)
create mode 100644 flink-python/pyflink/table/explain_detail.py
create mode 100644 flink-python/pyflink/table/tests/test_explain.py
copy
flink-table/flink-table-api-java/src/{test/java/org/apache/flink/table/utils/PlannerMock.java
=> main/java/org/apache/flink/table/api/ExplainDetail.java} (50%)
copy
flink-table/flink-table-api-java/src/{test/java/org/apache/flink/table/utils/PlannerMock.java
=> main/java/org/apache/flink/table/operations/ExplainOperation.java} (52%)
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/explain/testExecuteSqlWithExplainInsert.out
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/explain/testExecuteSqlWithExplainSelect.out
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/explain/testExplainSqlWithInsert.out
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/explain/testExplainSqlWithSelect.out
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/LogicalSink.scala
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/Sink.scala
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetSink.scala
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSink.scala
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalSink.scala
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/dataSet/DataSetSinkRule.scala
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamSinkRule.scala
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/sinks/DataStreamTableSink.scala
create mode 100644
flink-table/flink-table-planner/src/test/scala/resources/testExecuteSqlWithExplainInsert0.out
create mode 100644
flink-table/flink-table-planner/src/test/scala/resources/testExecuteSqlWithExplainInsert1.out
create mode 100644
flink-table/flink-table-planner/src/test/scala/resources/testExecuteSqlWithExplainSelect0.out
create mode 100644
flink-table/flink-table-planner/src/test/scala/resources/testExecuteSqlWithExplainSelect1.out
create mode 100644
flink-table/flink-table-planner/src/test/scala/resources/testExplainSqlWithInsert0.out
create mode 100644
flink-table/flink-table-planner/src/test/scala/resources/testExplainSqlWithInsert1.out
create mode 100644
flink-table/flink-table-planner/src/test/scala/resources/testExplainSqlWithSelect0.out
create mode 100644
flink-table/flink-table-planner/src/test/scala/resources/testExplainSqlWithSelect1.out
create mode 100644
flink-table/flink-table-planner/src/test/scala/resources/testInsert.out
create mode 100644
flink-table/flink-table-planner/src/test/scala/resources/testInsert1.out
create mode 100644
flink-table/flink-table-planner/src/test/scala/resources/testMultipleInserts.out
create mode 100644
flink-table/flink-table-planner/src/test/scala/resources/testMultipleInserts1.out
