public class DataCatalogTable
extends org.apache.flink.table.catalog.CatalogTableImpl
CatalogTableImpl
to wrap FileStoreTable
.Constructor and Description |
---|
DataCatalogTable(Table table,
org.apache.flink.table.api.TableSchema tableSchema,
List<String> partitionKeys,
Map<String,String> properties,
String comment,
Map<String,String> nonPhysicalColumnComments) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.table.catalog.CatalogBaseTable |
copy() |
org.apache.flink.table.catalog.CatalogTable |
copy(Map<String,String> options) |
org.apache.flink.table.api.Schema |
getUnresolvedSchema() |
Table |
table() |
fromProperties, getDescription, getDetailedDescription, removeRedundant, toProperties
getComment, getOptions, getPartitionKeys, getSchema, isPartitioned
public Table table()
public org.apache.flink.table.api.Schema getUnresolvedSchema()
public org.apache.flink.table.catalog.CatalogBaseTable copy()
copy
in interface org.apache.flink.table.catalog.CatalogBaseTable
copy
in class org.apache.flink.table.catalog.CatalogTableImpl
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.