org.apache.paimon.flink

Class DataCatalogTable

java.lang.Object

org.apache.flink.table.catalog.AbstractCatalogTable

org.apache.flink.table.catalog.CatalogTableImpl

org.apache.paimon.flink.DataCatalogTable

All Implemented Interfaces:

org.apache.flink.table.catalog.CatalogBaseTable, org.apache.flink.table.catalog.CatalogTable

public class DataCatalogTable
extends org.apache.flink.table.catalog.CatalogTableImpl

A CatalogTableImpl to wrap FileStoreTable.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.catalog.CatalogTable

org.apache.flink.table.catalog.CatalogTable.Builder

Nested classes/interfaces inherited from interface org.apache.flink.table.catalog.CatalogBaseTable

org.apache.flink.table.catalog.CatalogBaseTable.TableKind

Constructor Summary

Constructors

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)

Method Summary

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()

Methods inherited from class org.apache.flink.table.catalog.CatalogTableImpl

fromProperties, getDescription, getDetailedDescription, removeRedundant, toProperties

Methods inherited from class org.apache.flink.table.catalog.AbstractCatalogTable

getComment, getOptions, getPartitionKeys, getSchema, isPartitioned

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.table.catalog.CatalogTable

getDistribution, getSnapshot, getTableKind, newBuilder, of, of

Constructor Detail

DataCatalogTable

public DataCatalogTable(Table table,
                        org.apache.flink.table.api.TableSchema tableSchema,
                        List<String> partitionKeys,
                        Map<String,String> properties,
                        String comment,
                        Map<String,String> nonPhysicalColumnComments)

Method Detail

table

public Table table()

getUnresolvedSchema

public org.apache.flink.table.api.Schema getUnresolvedSchema()

copy

public org.apache.flink.table.catalog.CatalogBaseTable copy()

Specified by:

copy in interface org.apache.flink.table.catalog.CatalogBaseTable

Overrides:

copy in class org.apache.flink.table.catalog.CatalogTableImpl

copy

public org.apache.flink.table.catalog.CatalogTable copy(Map<String,String> options)

Specified by:

copy in interface org.apache.flink.table.catalog.CatalogTable

Overrides:

copy in class org.apache.flink.table.catalog.CatalogTableImpl