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 9ab85e1 [hotfix][table-planner] Disable
IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs until FLINK-24443 is
fixed
new 826b10f [FLINK-24399][table-common] Add DataTypes#of(LogicalType)
new b43e64b [FLINK-24399][table-common] Add DataType#toInternal
new 083e4d4 [FLINK-24399][table-common] Add DataType methods to improve
ergonomics when accessing row data type instances
new 66bd2ed [FLINK-24399][table-common] Improved DataType#getChildren
javadoc
new 3681e85 [FLINK-24399][table-common] Refactor
ResolvedSchema#to[...]RowDataType() methods and add new
ResolvedSchema#getPrimaryKeyIndexes
new 094bf1e [FLINK-24399][table-common] Fix DataTypeUtils#flattenToNames
javadoc
new 946a41c [FLINK-24399][table-common] Add
DynamicTableSource.Context#createTypeInformation(LogicalType) and
DynamicTableSink.Context#createTypeInformation(LogicalType)
new ac203a7 [FLINK-24399][table-common] Add
DynamicTableFactory.Context#getPrimaryKeyIndexes and
DynamicTableFactory.Context#getPhysicalRowDataType
The 8 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:
.../table/Elasticsearch6DynamicSinkITCase.java | 6 ++
.../table/Elasticsearch6DynamicSinkTest.java | 6 ++
.../table/Elasticsearch7DynamicSinkITCase.java | 6 ++
.../table/Elasticsearch7DynamicSinkTest.java | 6 ++
.../java/org/apache/flink/table/api/DataTypes.java | 11 ++
.../apache/flink/table/catalog/ResolvedSchema.java | 42 ++++----
.../table/connector/sink/DynamicTableSink.java | 6 ++
.../table/connector/source/DynamicTableSource.java | 14 ++-
.../flink/table/factories/DynamicTableFactory.java | 45 ++++++++
.../org/apache/flink/table/types/DataType.java | 117 +++++++++++++++++++++
.../flink/table/types/utils/DataTypeUtils.java | 7 +-
.../org/apache/flink/table/types/DataTypeTest.java | 72 +++++++++++++
.../table/filesystem/FileSystemTableSink.java | 6 ++
.../connector/sink/SinkRuntimeProviderContext.java | 6 ++
.../source/LookupRuntimeProviderContext.java | 6 ++
.../source/ScanRuntimeProviderContext.java | 6 ++
16 files changed, 338 insertions(+), 24 deletions(-)
