This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 329fa85 [FLINK-14683] Fix RemoteStreamEnvironment's constructor
new 9569cc8 [hotfix][table-common] Add utility method for checking if a
type is a composite type
new c6ba704 [hotfix][table-common] Add utility for expanding a composite
type to a schema.
new 79ec3ba [hotfix][table-api] Add utility for extracting accessed
fields from a given physical type.
new 23a4782 [hotfix][table-common] Add utility for mapping logical fields
to physical indices.
new 833b46b [hotfix][table] Remove duplicated code for physical to
logical mapping
new 422ab8a [FLINK-15168][table-planner] Fix physical indices computing.
new 4a8fa1f [hotfix][table-planner-blink, tests] Fix produced data type
of TestCollectionTableSource.
new 69e7358 [FLINK-15168][table-planner-blink] Compute physical indices
based on new type hierarchy instead of TypeInformation
new 4e3fb3c [hotfix][table-common] Deprecate TableSource#getSchema.
new f65481f [hotfix][connectors/jdbc, table, tests] Fix types in schema
ddl in tests
new 6b8fd32 [hotfix][connectors/kafka, table, tests] Fix types in schema
ddl in tests
The 11 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:
.../kafka/KafkaTableSourceSinkFactoryTestBase.java | 20 +-
.../connectors/kafka/KafkaTableTestBase.java | 6 +-
.../io/jdbc/JDBCTableSourceSinkFactoryTest.java | 6 +-
.../table/api/internal/TableEnvironmentImpl.java | 2 +-
.../flink/table/catalog/ConnectorCatalogTable.java | 6 +-
.../apache/flink/table/sources/TableSource.java | 3 +
.../flink/table/sources/TableSourceValidation.java | 230 ++----------
.../tsextractors/TimestampExtractorUtils.java | 95 +++++
.../types/logical/utils/LogicalTypeChecks.java | 16 +
.../flink/table/types/utils/DataTypeUtils.java | 103 ++++-
.../apache/flink/table/utils/TypeMappingUtils.java | 295 +++++++++++++++
.../types/logical/utils/LogicalTypeChecksTest.java | 109 ++++++
.../flink/table/types/utils/DataTypeUtilsTest.java | 153 ++++++++
.../flink/table/utils/TypeMappingUtilsTest.java | 373 ++++++++++++++++++
.../table/planner/calcite/FlinkTypeFactory.scala | 13 +
.../physical/batch/BatchExecTableSourceScan.scala | 50 ++-
.../stream/StreamExecTableSourceScan.scala | 52 ++-
.../table/planner/sources/TableSourceUtil.scala | 314 ++++------------
.../utils/TestCollectionTableFactory.scala | 3 +-
.../flink/table/catalog/DatabaseCalciteSchema.java | 2 +
.../flink/table/plan/QueryOperationConverter.java | 2 +
.../table/api/internal/BatchTableEnvImpl.scala | 2 +-
.../table/plan/nodes/PhysicalTableSourceScan.scala | 15 +-
.../plan/nodes/dataset/BatchTableSourceScan.scala | 82 ++--
.../nodes/datastream/StreamTableSourceScan.scala | 77 ++--
.../logical/FlinkLogicalTableSourceScan.scala | 38 +-
.../rules/dataSet/BatchTableSourceScanRule.scala | 1 +
.../datastream/StreamTableSourceScanRule.scala | 1 +
.../PushFilterIntoTableSourceScanRule.scala | 2 +-
.../PushProjectIntoTableSourceScanRule.scala | 103 ++++-
.../flink/table/plan/schema/TableSourceTable.scala | 66 +++-
.../flink/table/sources/TableSourceUtil.scala | 417 ++++-----------------
.../table/catalog/CatalogStructureBuilder.java | 10 +-
33 files changed, 1745 insertions(+), 922 deletions(-)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/tsextractors/TimestampExtractorUtils.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/TypeMappingUtils.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/logical/utils/LogicalTypeChecksTest.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/utils/DataTypeUtilsTest.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/TypeMappingUtilsTest.java
