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