public class SourceAbilityContext extends Object implements org.apache.flink.table.planner.calcite.FlinkContext
FlinkContext
which contains the information for SourceAbilitySpec
to apply the following abilities to DynamicTableSource
.
Constructor and Description |
---|
SourceAbilityContext(org.apache.flink.table.planner.calcite.FlinkContext context,
RowType sourceRowType) |
Modifier and Type | Method and Description |
---|---|
static SourceAbilityContext |
from(org.apache.calcite.rel.core.TableScan scan) |
CatalogManager |
getCatalogManager() |
FunctionCatalog |
getFunctionCatalog() |
ModuleManager |
getModuleManager() |
RowType |
getSourceRowType() |
SqlExprToRexConverterFactory |
getSqlExprToRexConverterFactory() |
TableConfig |
getTableConfig() |
boolean |
isBatchMode() |
<C> C |
unwrap(Class<C> clazz) |
public SourceAbilityContext(org.apache.flink.table.planner.calcite.FlinkContext context, RowType sourceRowType)
public boolean isBatchMode()
isBatchMode
in interface org.apache.flink.table.planner.calcite.FlinkContext
public TableConfig getTableConfig()
getTableConfig
in interface org.apache.flink.table.planner.calcite.FlinkContext
public FunctionCatalog getFunctionCatalog()
getFunctionCatalog
in interface org.apache.flink.table.planner.calcite.FlinkContext
public CatalogManager getCatalogManager()
getCatalogManager
in interface org.apache.flink.table.planner.calcite.FlinkContext
public ModuleManager getModuleManager()
getModuleManager
in interface org.apache.flink.table.planner.calcite.FlinkContext
public SqlExprToRexConverterFactory getSqlExprToRexConverterFactory()
getSqlExprToRexConverterFactory
in interface org.apache.flink.table.planner.calcite.FlinkContext
public <C> C unwrap(Class<C> clazz)
unwrap
in interface org.apache.calcite.schema.Wrapper
unwrap
in interface org.apache.flink.table.planner.calcite.FlinkContext
public RowType getSourceRowType()
public static SourceAbilityContext from(org.apache.calcite.rel.core.TableScan scan)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.