public class SystemCatalogTable extends Object implements org.apache.flink.table.catalog.CatalogTable
CatalogTable
to represent system table.Constructor and Description |
---|
SystemCatalogTable(Table table) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.table.catalog.CatalogTable |
copy() |
org.apache.flink.table.catalog.CatalogTable |
copy(Map<String,String> map) |
String |
getComment() |
Optional<String> |
getDescription() |
Optional<String> |
getDetailedDescription() |
Map<String,String> |
getOptions() |
List<String> |
getPartitionKeys() |
org.apache.flink.table.api.Schema |
getUnresolvedSchema() |
boolean |
isPartitioned() |
Table |
table() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public SystemCatalogTable(Table table)
public Table table()
public org.apache.flink.table.api.Schema getUnresolvedSchema()
getUnresolvedSchema
in interface org.apache.flink.table.catalog.CatalogBaseTable
public boolean isPartitioned()
isPartitioned
in interface org.apache.flink.table.catalog.CatalogTable
public List<String> getPartitionKeys()
getPartitionKeys
in interface org.apache.flink.table.catalog.CatalogTable
public org.apache.flink.table.catalog.CatalogTable copy(Map<String,String> map)
copy
in interface org.apache.flink.table.catalog.CatalogTable
public Map<String,String> getOptions()
getOptions
in interface org.apache.flink.table.catalog.CatalogBaseTable
public String getComment()
getComment
in interface org.apache.flink.table.catalog.CatalogBaseTable
public org.apache.flink.table.catalog.CatalogTable copy()
copy
in interface org.apache.flink.table.catalog.CatalogBaseTable
public Optional<String> getDescription()
getDescription
in interface org.apache.flink.table.catalog.CatalogBaseTable
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.