This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from a27d73a [FLINK-14683] Fix RemoteStreamEnvironment's constructor
add 22020e1 [hotfix][table-common] Add utility method for checking if a
type is a composite type
add 958663b [hotfix][table-common] Add utility for expanding a composite
type to a schema.
add 21107c7 [hotfix][table-api] Add utility for extracting accessed
fields from a given physical type.
add cbc1005 [hotfix][table-common] Add utility for mapping logical fields
to physical indices.
add 170a822 [hotfix][table] Remove duplicated code for physical to
logical mapping
add 39b7992 [FLINK-15168][table-planner] Fix physical indices computing.
add cd36331 [hotfix][table-planner-blink, tests] Fix produced data type
of TestCollectionTableSource.
add 1960b27 [FLINK-15168][table-planner-blink] Compute physical indices
based on new type hierarchy instead of TypeInformation
add d49ee21 [hotfix][table-common] Deprecate TableSource#getSchema.
add 8990e4a [hotfix][connectors/jdbc, table, tests] Fix types in schema
ddl in tests
add 5249249 [hotfix][connectors/kafka, table, tests] Fix types in schema
ddl in tests
No new revisions were added by this update.
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
