[flink] branch master updated (5027e42 -> a8b2f17)

[tw...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 5027e42  [hotfix][docs] Fix example
     add 2cda6b7  [FLINK-25841][table] Introduce new APIs for FLIP-190 single statement plan compilation
     add a8b2f17  [FLINK-25841][table] Add helpful JavaDocs at various locations

No new revisions were added by this update.

Summary of changes:
 .../flink/formats/csv/TableCsvFormatITCase.java    |  36 ++--
 .../table/tests/test_environment_completeness.py   |   7 +-
 .../pyflink/table/tests/test_pandas_udaf.py        |   4 +-
 flink-python/pyflink/table/tests/test_udaf.py      |  28 +--
 flink-python/pyflink/table/tests/test_udf.py       |  10 +-
 flink-python/pyflink/table/tests/test_udtf.py      |  12 +-
 .../org/apache/flink/table/api/CompiledPlan.java   | 103 +++++++++++
 .../org/apache/flink/table/api/PlanReference.java  | 200 +++++++++++++++++++++
 .../apache/flink/table/api/TableEnvironment.java   |  67 +++++++
 .../table/api/internal/CompiledPlanInternal.java}  |  18 +-
 .../flink/table/api/internal/StatementSetImpl.java |  13 +-
 .../table/api/internal/TableEnvironmentImpl.java   |  93 +++++-----
 .../api/internal/TableEnvironmentInternal.java     |  56 +-----
 .../org/apache/flink/table/delegation/Planner.java |  50 ++----
 .../org/apache/flink/table/utils/PlannerMock.java  |  15 +-
 .../plan/nodes/exec/serde/JsonPlanGraph.java       |   2 +-
 .../table/planner/delegation/BatchPlanner.scala    |  22 ++-
 .../table/planner/delegation/PlannerBase.scala     |  54 +++---
 .../table/planner/delegation/StreamPlanner.scala   |  35 ++--
 .../planner/plan/ExecNodeGraphCompiledPlan.java    |  92 ++++++++++
 .../table/api/internal/StatementSetImplTest.java   |   2 +-
 .../api/internal/TableEnvironmentInternalTest.java |  53 +++---
 .../nodes/exec/stream/LookupJoinJsonPlanTest.java  |  17 +-
 .../stream/jsonplan/CalcJsonPlanITCase.java        |  14 +-
 .../jsonplan/ChangelogSourceJsonPlanITCase.java    |   4 +-
 .../stream/jsonplan/CorrelateJsonPlanITCase.java   |  10 +-
 .../jsonplan/DeduplicationJsonPlanITCase.java      |   7 +-
 .../stream/jsonplan/ExpandJsonPlanITCase.java      |   7 +-
 .../jsonplan/GroupAggregateJsonPlanITCase.java     |  25 +--
 .../jsonplan/GroupWindowAggregateJsonITCase.java   |  19 +-
 .../IncrementalAggregateJsonPlanITCase.java        |   7 +-
 .../jsonplan/IntervalJoinJsonPlanITCase.java       |  13 +-
 .../stream/jsonplan/JoinJsonPlanITCase.java        |  37 ++--
 .../stream/jsonplan/LimitJsonPlanITCase.java       |   2 +-
 .../stream/jsonplan/LookupJoinJsonPlanITCase.java  |  13 +-
 .../jsonplan/MatchRecognizeJsonPlanITCase.java     |   4 +-
 .../jsonplan/OverAggregateJsonPlanITCase.java      |   6 +-
 .../stream/jsonplan/RankJsonPlanITCase.java        |   4 +-
 .../stream/jsonplan/SortLimitJsonPlanITCase.java   |   2 +-
 .../stream/jsonplan/TableSinkJsonPlanITCase.java   |  12 +-
 .../stream/jsonplan/TableSourceJsonPlanITCase.java |  36 ++--
 .../jsonplan/TemporalJoinJsonPlanITCase.java       |  15 +-
 .../stream/jsonplan/TemporalSortJsonITCase.java    |  14 +-
 .../stream/jsonplan/UnionJsonPlanITCase.java       |   2 +-
 .../stream/jsonplan/ValuesJsonPlanITCase.java      |   7 +-
 .../jsonplan/WatermarkAssignerJsonPlanITCase.java  |   8 +-
 .../stream/jsonplan/WindowAggregateJsonITCase.java |  25 +--
 .../jsonplan/WindowDeduplicateJsonITCase.java      |   7 +-
 .../stream/jsonplan/WindowJoinJsonITCase.java      |   7 +-
 .../jsonplan/WindowTableFunctionJsonITCase.java    |   7 +-
 .../table/planner/utils/JsonPlanTestBase.java      |   4 +-
 .../flink/table/planner/utils/TableTestBase.scala  |   4 +-
 52 files changed, 894 insertions(+), 417 deletions(-)
 create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/CompiledPlan.java
 create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/PlanReference.java
 copy flink-table/{flink-table-common/src/main/java/org/apache/flink/table/descriptors/DescriptorValidator.java => flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/CompiledPlanInternal.java} (68%)
 create mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/ExecNodeGraphCompiledPlan.java