org.apache.flink.table.catalog

Class AbstractCatalogView

java.lang.Object

org.apache.flink.table.catalog.AbstractCatalogView

All Implemented Interfaces:

CatalogBaseTable, CatalogView

Direct Known Subclasses:

CatalogViewImpl, QueryOperationCatalogView

public abstract class AbstractCatalogView
extends Object
implements CatalogView

An abstract catalog view.

Constructor Summary

Constructors

Constructor and Description
AbstractCatalogView(String originalQuery, String expandedQuery, TableSchema schema, Map<String,String> properties, String comment)

Method Summary

Modifier and Type	Method and Description
String	getComment() Get comment of the table or view.
String	getExpandedQuery() Expanded text of the original view definition This is needed because the context such as current DB is lost after the session, in which view is defined, is gone.
String	getOriginalQuery() Original text of the view definition that also perserves the original formatting.
Map<String,String>	getProperties()
TableSchema	getSchema() Get the schema of the 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.CatalogBaseTable

copy, getDescription, getDetailedDescription, getOptions

Constructor Detail

AbstractCatalogView

public AbstractCatalogView(String originalQuery,
                           String expandedQuery,
                           TableSchema schema,
                           Map<String,String> properties,
                           String comment)

Method Detail

getOriginalQuery

public String getOriginalQuery()

Description copied from interface: CatalogView

Original text of the view definition that also perserves the original formatting.

Specified by:

getOriginalQuery in interface CatalogView

Returns:

the original string literal provided by the user.

getExpandedQuery

public String getExpandedQuery()

Description copied from interface: CatalogView

Expanded text of the original view definition This is needed because the context such as current DB is lost after the session, in which view is defined, is gone. Expanded query text takes care of this, as an example.

For example, for a view that is defined in the context of "default" database with a query select * from test1, the expanded query text might become select `test1`.`name`, `test1`.`value` from `default`.`test1`, where table test1 resides in database "default" and has two columns ("name" and "value").

Specified by:

getExpandedQuery in interface CatalogView

Returns:

the view definition in expanded text.

getProperties

public Map<String,String> getProperties()

Specified by:

getProperties in interface CatalogBaseTable

getSchema

public TableSchema getSchema()

Description copied from interface: CatalogBaseTable

Get the schema of the table.

Specified by:

getSchema in interface CatalogBaseTable

Returns:

schema of the table/view.

getComment

public String getComment()

Description copied from interface: CatalogBaseTable

Get comment of the table or view.

Specified by:

getComment in interface CatalogBaseTable

Returns:

comment of the table/view.