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 7a75e97 [FLINK-21632][python] Add NamespacedStateView and
PerWindowStateDataViewStore
add 9035273 [hotfix][table-common] Move CatalogConfig to
CatalogPropertiesUtil
add d3b1531 [FLINK-21396][table-common] Add ResolvedCatalog(View/Table)
and Catalog(View/Table).of
No new revisions were added by this update.
Summary of changes:
.../connectors/hive/HiveDynamicTableFactory.java | 12 +-
.../flink/connectors/hive/HiveTableFactory.java | 8 +-
.../flink/table/catalog/hive/HiveCatalog.java | 19 +-
.../table/catalog/hive/util/HiveTableUtil.java | 6 +-
.../flink/connectors/hive/HiveDialectITCase.java | 4 +-
.../connectors/hive/HiveTableFactoryTest.java | 6 +-
.../catalog/hive/HiveCatalogDataTypeTest.java | 4 +-
.../hive/HiveCatalogGenericMetadataTest.java | 4 +-
.../catalog/hive/HiveCatalogHiveMetadataTest.java | 4 +-
.../flink/table/catalog/hive/HiveCatalogTest.java | 12 +-
.../table/client/gateway/local/DependencyTest.java | 10 +-
.../flink/sql/parser/hive/ddl/HiveDDLUtils.java | 4 +-
.../sql/parser/hive/ddl/SqlCreateHiveDatabase.java | 5 +-
.../sql/parser/hive/ddl/SqlCreateHiveTable.java | 5 +-
.../sql/parser/hive/ddl/SqlCreateHiveView.java | 4 +-
.../flink/table/catalog/CatalogTableBuilder.java | 3 +-
.../flink/table/catalog/CatalogTableImpl.java | 3 +-
.../catalog/CatalogBaseTableResolutionTest.java | 263 +++++++++++
.../flink/table/catalog/CatalogTestBase.java | 6 +-
.../flink/table/catalog/SchemaResolutionTest.java | 31 +-
.../flink/table/utils/ExpressionResolverMocks.java | 62 +++
.../flink/table/catalog/CatalogPropertiesUtil.java | 495 +++++++++++++++++++++
.../apache/flink/table/catalog/CatalogTable.java | 52 ++-
.../apache/flink/table/catalog/CatalogView.java | 41 +-
.../flink/table/catalog/DefaultCatalogTable.java | 137 ++++++
.../flink/table/catalog/DefaultCatalogView.java | 129 ++++++
.../table/catalog/ResolvedCatalogBaseTable.java | 56 +++
.../flink/table/catalog/ResolvedCatalogTable.java | 114 +++++
.../flink/table/catalog/ResolvedCatalogView.java | 99 +++++
.../flink/table/catalog/config/CatalogConfig.java | 33 --
.../table/descriptors/DescriptorProperties.java | 7 +
.../flink/table/catalog/CatalogTestUtil.java | 13 +-
32 files changed, 1526 insertions(+), 125 deletions(-)
create mode 100644
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/CatalogBaseTableResolutionTest.java
create mode 100644
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/utils/ExpressionResolverMocks.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogPropertiesUtil.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/DefaultCatalogTable.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/DefaultCatalogView.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ResolvedCatalogBaseTable.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ResolvedCatalogTable.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ResolvedCatalogView.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/config/CatalogConfig.java
