org.apache.flink.table.factories

Class TableSourceFactoryContextImpl

java.lang.Object

org.apache.flink.table.factories.TableSourceFactoryContextImpl

All Implemented Interfaces:

TableSourceFactory.Context

@Internal
public class TableSourceFactoryContextImpl
extends Object
implements TableSourceFactory.Context

Implementation of TableSourceFactory.Context.

Constructor Summary

Constructors

Constructor and Description
TableSourceFactoryContextImpl(ObjectIdentifier identifier, CatalogTable table, ReadableConfig config)

Method Summary

Modifier and Type	Method and Description
ReadableConfig	getConfiguration()
ObjectIdentifier	getObjectIdentifier()
CatalogTable	getTable()

Methods inherited from class java.lang.Object

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

Constructor Detail

TableSourceFactoryContextImpl

public TableSourceFactoryContextImpl(ObjectIdentifier identifier,
                                     CatalogTable table,
                                     ReadableConfig config)

Method Detail

getObjectIdentifier

public ObjectIdentifier getObjectIdentifier()

Specified by:

getObjectIdentifier in interface TableSourceFactory.Context

Returns:

full identifier of the given CatalogTable.

getTable

public CatalogTable getTable()

Specified by:

getTable in interface TableSourceFactory.Context

Returns:

table CatalogTable instance.

getConfiguration

public ReadableConfig getConfiguration()

Specified by:

getConfiguration in interface TableSourceFactory.Context

Returns:

readable config of this table environment. The configuration gives the ability to access TableConfig#getConfiguration() which holds the current TableEnvironment session configurations.