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

Class SourceAbilityContext

java.lang.Object

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

All Implemented Interfaces:

org.apache.calcite.plan.Context, org.apache.calcite.schema.Wrapper, org.apache.flink.table.planner.calcite.FlinkContext

public class SourceAbilityContext
extends Object
implements org.apache.flink.table.planner.calcite.FlinkContext

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(org.apache.flink.table.planner.calcite.FlinkContext context, org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory, RowType sourceRowType)

Method Summary

Modifier and Type	Method and Description
static SourceAbilityContext	from(org.apache.calcite.rel.core.TableScan scan)
CatalogManager	getCatalogManager()
ClassLoader	getClassLoader()
FunctionCatalog	getFunctionCatalog()
ModuleManager	getModuleManager()
RexFactory	getRexFactory()
RowType	getSourceRowType()
TableConfig	getTableConfig()
org.apache.flink.table.planner.calcite.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

Methods inherited from interface org.apache.flink.table.planner.calcite.FlinkContext

$init$

Methods inherited from interface org.apache.calcite.schema.Wrapper

maybeUnwrap, unwrapOrThrow

Constructor Detail

SourceAbilityContext

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

Method Detail

isBatchMode

public boolean isBatchMode()

Specified by:

isBatchMode in interface org.apache.flink.table.planner.calcite.FlinkContext

getClassLoader

public ClassLoader getClassLoader()

Specified by:

getClassLoader in interface org.apache.flink.table.planner.calcite.FlinkContext

getTableConfig

public TableConfig getTableConfig()

Specified by:

getTableConfig in interface org.apache.flink.table.planner.calcite.FlinkContext

getFunctionCatalog

public FunctionCatalog getFunctionCatalog()

Specified by:

getFunctionCatalog in interface org.apache.flink.table.planner.calcite.FlinkContext

getCatalogManager

public CatalogManager getCatalogManager()

Specified by:

getCatalogManager in interface org.apache.flink.table.planner.calcite.FlinkContext

getModuleManager

public ModuleManager getModuleManager()

Specified by:

getModuleManager in interface org.apache.flink.table.planner.calcite.FlinkContext

getRexFactory

public RexFactory getRexFactory()

Specified by:

getRexFactory in interface org.apache.flink.table.planner.calcite.FlinkContext

getTypeFactory

public org.apache.flink.table.planner.calcite.FlinkTypeFactory getTypeFactory()

unwrap

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

Specified by:

unwrap in interface org.apache.calcite.schema.Wrapper

Specified by:

unwrap in interface org.apache.flink.table.planner.calcite.FlinkContext

getSourceRowType

public RowType getSourceRowType()

from

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