[flink] branch master updated (075644a -> c6960eb)

[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 075644a  [FLINK-21801][table-common] Deprecate TableSchema and related classes
     add c6960eb  [FLINK-21801][table-api] Use ResolvedSchema in QueryOperation

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/table/tests/test_calc.py      |  4 +-
 .../pyflink/table/tests/test_column_operation.py   |  4 +-
 .../arrow/sources/AbstractArrowTableSource.java    |  2 +-
 .../java/internal/StreamTableEnvironmentImpl.java  |  4 +-
 .../table/operations/DataSetQueryOperation.java    | 14 ++--
 .../operations/JavaDataStreamQueryOperation.java   | 17 ++--
 .../table/api/internal/TableEnvironmentImpl.java   |  8 +-
 .../apache/flink/table/api/internal/TableImpl.java |  4 +-
 .../table/catalog/QueryOperationCatalogView.java   |  3 +-
 .../expressions/TableReferenceExpression.java      |  2 +-
 .../resolver/lookups/FieldReferenceLookup.java     | 10 +--
 .../table/functions/TemporalTableFunctionImpl.java | 13 +--
 .../table/operations/AggregateQueryOperation.java  | 12 +--
 .../table/operations/CalculatedQueryOperation.java | 12 +--
 .../table/operations/CatalogQueryOperation.java    | 14 ++--
 .../table/operations/DistinctQueryOperation.java   |  6 +-
 .../table/operations/FilterQueryOperation.java     |  6 +-
 .../flink/table/operations/JoinQueryOperation.java | 50 +++++------
 .../table/operations/ProjectQueryOperation.java    | 14 ++--
 .../flink/table/operations/QueryOperation.java     |  4 +-
 .../flink/table/operations/SetQueryOperation.java  | 12 +--
 .../flink/table/operations/SortQueryOperation.java |  6 +-
 .../operations/TableSourceQueryOperation.java      |  7 +-
 .../table/operations/ValuesQueryOperation.java     | 18 ++--
 .../operations/WindowAggregateQueryOperation.java  | 12 +--
 .../utils/AggregateOperationFactory.java           | 16 ++--
 .../operations/utils/AliasOperationUtils.java      | 13 +--
 .../operations/utils/CalculatedTableFactory.java   | 33 ++++----
 .../operations/utils/JoinOperationFactory.java     |  6 +-
 .../operations/utils/OperationTreeBuilder.java     | 57 +++++++------
 .../utils/ProjectionOperationFactory.java          |  7 +-
 .../operations/utils/SetOperationFactory.java      | 42 +++++-----
 .../operations/utils/ValuesOperationFactory.java   | 20 ++---
 .../flink/table/typeutils/FieldInfoUtils.java      |  5 +-
 .../resolver/ExpressionResolverTest.java           |  6 +-
 .../flink/table/operations/QueryOperationTest.java | 10 ++-
 .../utils/ValuesOperationTreeBuilderTest.java      | 61 +++++++-------
 .../operations/ScalaDataStreamQueryOperation.java  | 17 ++--
 .../internal/StreamTableEnvironmentImpl.scala      |  4 +-
 .../apache/flink/table/catalog/ResolvedSchema.java | 43 ++++++++++
 .../tsextractors/TimestampExtractorUtils.java      | 13 ++-
 .../flink/table/types/utils/DataTypeUtils.java     | 41 ++++-----
 .../apache/flink/table/utils/TypeMappingUtils.java | 13 +--
 .../flink/table/types/utils/DataTypeUtilsTest.java | 56 ++++++-------
 .../flink/table/utils/TypeMappingUtilsTest.java    |  7 +-
 .../operations/DataStreamQueryOperation.java       | 15 ++--
 .../planner/operations/PlannerQueryOperation.java  | 10 +--
 .../operations/SqlToOperationConverter.java        | 28 ++++---
 .../planner/plan/QueryOperationConverter.java      | 33 ++++----
 .../table/planner/delegation/PlannerBase.scala     |  3 +-
 .../flink/table/planner/expressions/subquery.scala |  9 +-
 .../flink/table/planner/sinks/TableSinkUtils.scala |  7 +-
 .../flink/table/planner/utils/TableTestBase.scala  |  5 +-
 .../flink/table/plan/QueryOperationConverter.java  | 28 ++++---
 .../table/sqlexec/SqlToOperationConverter.java     | 30 ++++---
 .../table/api/internal/BatchTableEnvImpl.scala     | 16 ++--
 .../flink/table/api/internal/TableEnvImpl.scala    |  4 +-
 .../apache/flink/table/expressions/subquery.scala  |  3 +-
 .../table/operations/PlannerQueryOperation.java    | 98 +++++++++++-----------
 .../PushProjectIntoTableSourceScanRule.scala       |  3 +-
 .../flink/table/plan/schema/TableSourceTable.scala |  2 +-
 .../apache/flink/table/planner/StreamPlanner.scala |  5 +-
 .../apache/flink/table/sinks/TableSinkUtils.scala  |  7 +-
 .../apache/flink/table/utils/TableTestBase.scala   |  7 +-
 64 files changed, 567 insertions(+), 474 deletions(-)