org.apache.paimon.flink

Class FormatCatalogTable

java.lang.Object

org.apache.paimon.flink.FormatCatalogTable

All Implemented Interfaces:

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

public class FormatCatalogTable
extends Object
implements org.apache.flink.table.catalog.CatalogTable

A CatalogTable to represent format table.

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
FormatCatalogTable(FormatTable table)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.table.catalog.CatalogTable	copy()
org.apache.flink.table.catalog.CatalogTable	copy(Map<String,String> map)
org.apache.flink.table.connector.sink.DynamicTableSink	createTableSink(org.apache.flink.table.factories.DynamicTableFactory.Context context)
org.apache.flink.table.connector.source.DynamicTableSource	createTableSource(org.apache.flink.table.factories.DynamicTableFactory.Context context)
String	getComment()
Optional<String>	getDescription()
Optional<String>	getDetailedDescription()
Map<String,String>	getOptions()
List<String>	getPartitionKeys()
org.apache.flink.table.api.Schema	getUnresolvedSchema()
boolean	isPartitioned()
FormatTable	table()

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

fromProperties, getDistribution, getSnapshot, getTableKind, newBuilder, of, of, toProperties

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

getSchema

Constructor Detail

FormatCatalogTable

public FormatCatalogTable(FormatTable table)

Method Detail

table

public FormatTable table()

getUnresolvedSchema

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

Specified by:

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

isPartitioned

public boolean isPartitioned()

Specified by:

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

getPartitionKeys

public List<String> getPartitionKeys()

Specified by:

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

copy

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

Specified by:

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

getOptions

public Map<String,String> getOptions()

Specified by:

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

getComment

public String getComment()

Specified by:

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

copy

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

Specified by:

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

getDescription

public Optional<String> getDescription()

Specified by:

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

getDetailedDescription

public Optional<String> getDetailedDescription()

Specified by:

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

createTableSource

public org.apache.flink.table.connector.source.DynamicTableSource createTableSource(org.apache.flink.table.factories.DynamicTableFactory.Context context)

createTableSink

public org.apache.flink.table.connector.sink.DynamicTableSink createTableSink(org.apache.flink.table.factories.DynamicTableFactory.Context context)