org.apache.flink.table.planner.plan.abilities.source

Class SourceAbilityContext

java.lang.Object

org.apache.flink.table.planner.plan.abilities.source.SourceAbilityContext

public class SourceAbilityContext
extends Object

A sub-class of FlinkContext which contains the information for SourceAbilitySpec to apply the following abilities to DynamicTableSource.

• filter push down (SupportsFilterPushDown)
• project push down (SupportsProjectionPushDown)
• partition push down (SupportsPartitionPushDown)
• watermark push down (SupportsWatermarkPushDown)
• aggregate push down (SupportsAggregatePushDown)
• reading metadata (SupportsReadingMetadata)

Constructor Summary

Constructors

Constructor and Description
SourceAbilityContext(FlinkContext context, FlinkTypeFactory typeFactory, org.apache.flink.table.types.logical.RowType sourceRowType)

Method Summary

Modifier and Type	Method and Description
static SourceAbilityContext	from(org.apache.calcite.rel.core.TableScan scan)
org.apache.flink.table.catalog.CatalogManager	getCatalogManager()
ClassLoader	getClassLoader()
org.apache.flink.table.catalog.FunctionCatalog	getFunctionCatalog()
org.apache.flink.table.module.ModuleManager	getModuleManager()
RexFactory	getRexFactory()
org.apache.flink.table.types.logical.RowType	getSourceRowType()
org.apache.flink.table.api.TableConfig	getTableConfig()
FlinkTypeFactory	getTypeFactory()
boolean	isBatchMode()
<C> C	unwrap(Class<C> clazz)

Methods inherited from class java.lang.Object

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

Constructor Detail

SourceAbilityContext

public SourceAbilityContext(FlinkContext context,
                            FlinkTypeFactory typeFactory,
                            org.apache.flink.table.types.logical.RowType sourceRowType)

Method Detail

isBatchMode

public boolean isBatchMode()

getClassLoader

public ClassLoader getClassLoader()

getTableConfig

public org.apache.flink.table.api.TableConfig getTableConfig()

getFunctionCatalog

public org.apache.flink.table.catalog.FunctionCatalog getFunctionCatalog()

getCatalogManager

public org.apache.flink.table.catalog.CatalogManager getCatalogManager()

getModuleManager

public org.apache.flink.table.module.ModuleManager getModuleManager()

getRexFactory

public RexFactory getRexFactory()

getTypeFactory

public FlinkTypeFactory getTypeFactory()

unwrap

public <C> C unwrap(Class<C> clazz)

getSourceRowType

public org.apache.flink.table.types.logical.RowType getSourceRowType()

from

public static SourceAbilityContext from(org.apache.calcite.rel.core.TableScan scan)