org.apache.flink.table.catalog

Interface CatalogView

All Superinterfaces:

CatalogBaseTable

All Known Implementing Classes:

AbstractCatalogView, CatalogViewImpl, QueryOperationCatalogView

public interface CatalogView
extends CatalogBaseTable

Represents a view in a catalog.

Method Summary

Modifier and Type	Method and Description
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.

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

copy, getComment, getDescription, getDetailedDescription, getOptions, getProperties, getSchema

Method Detail

getOriginalQuery

String getOriginalQuery()

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

Returns:

the original string literal provided by the user.

getExpandedQuery

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. 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").

Returns:

the view definition in expanded text.