org.apache.flink.table.catalog

Class CatalogTableImpl

java.lang.Object

org.apache.flink.table.catalog.AbstractCatalogTable

org.apache.flink.table.catalog.CatalogTableImpl

All Implemented Interfaces:

CatalogBaseTable, CatalogTable

Deprecated.

Use CatalogTable.of(Schema, String, List, Map) or a custom implementation instead. Don't implement against this internal class. It can lead to unintended side effects if code checks against this class instead of the common interface.

@Deprecated
 @Internal
public class CatalogTableImpl
extends AbstractCatalogTable

A catalog table implementation.

Nested Class Summary

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

CatalogBaseTable.TableKind

Constructor Summary

Constructors

Constructor and Description
CatalogTableImpl(TableSchema tableSchema, List<String> partitionKeys, Map<String,String> properties, String comment) Deprecated.
CatalogTableImpl(TableSchema tableSchema, Map<String,String> properties, String comment) Deprecated.

Method Summary

Modifier and Type	Method and Description
CatalogBaseTable	copy() Deprecated. Get a deep copy of the CatalogBaseTable instance.
CatalogTable	copy(Map<String,String> options) Deprecated. Returns a copy of this CatalogTable with given table options options.
static CatalogTableImpl	fromProperties(Map<String,String> properties) Deprecated. Construct a CatalogTableImpl from complete properties that contains table schema.
Optional<String>	getDescription() Deprecated. Get a brief description of the table or view.
Optional<String>	getDetailedDescription() Deprecated. Get a detailed description of the table or view.
static Map<String,String>	removeRedundant(Map<String,String> properties, TableSchema schema, List<String> partitionKeys) Deprecated. Construct catalog table properties from toProperties().
Map<String,String>	toProperties() Deprecated. Serializes this instance into a map of string-based properties.

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

getTableKind, of

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

getUnresolvedSchema

Constructor Detail

CatalogTableImpl

public CatalogTableImpl(TableSchema tableSchema,
                        Map<String,String> properties,
                        String comment)

Deprecated.

CatalogTableImpl

public CatalogTableImpl(TableSchema tableSchema,
                        List<String> partitionKeys,
                        Map<String,String> properties,
                        String comment)

Deprecated.

Method Detail

copy

public CatalogBaseTable copy()

Deprecated.

Description copied from interface: CatalogBaseTable

Get a deep copy of the CatalogBaseTable instance.

Returns:

a copy of the CatalogBaseTable instance

getDescription

public Optional<String> getDescription()

Deprecated.

Description copied from interface: CatalogBaseTable

Get a brief description of the table or view.

Returns:

an optional short description of the table/view

getDetailedDescription

public Optional<String> getDetailedDescription()

Deprecated.

Description copied from interface: CatalogBaseTable

Get a detailed description of the table or view.

Returns:

an optional long description of the table/view

toProperties

public Map<String,String> toProperties()

Deprecated.

Description copied from interface: CatalogTable

Serializes this instance into a map of string-based properties.

Compared to the pure table options in CatalogBaseTable.getOptions(), the map includes schema, partitioning, and other characteristics in a serialized form.

copy

public CatalogTable copy(Map<String,String> options)

Deprecated.

Description copied from interface: CatalogTable

Returns a copy of this CatalogTable with given table options options.

Returns:

a new copy of this table with replaced table options

fromProperties

public static CatalogTableImpl fromProperties(Map<String,String> properties)

Deprecated.

Construct a CatalogTableImpl from complete properties that contains table schema.

Parameters:

properties - serialized version of a CatalogTable that includes schema, partition keys, and connector options

removeRedundant

public static Map<String,String> removeRedundant(Map<String,String> properties,
                                                 TableSchema schema,
                                                 List<String> partitionKeys)

Deprecated.

Construct catalog table properties from toProperties().