public class CatalogSchemaTable
extends org.apache.calcite.schema.impl.AbstractTable
implements org.apache.calcite.schema.TemporalTable
CatalogBaseTable
in Schema
.
This table would be converted to FlinkPreparingTableBase
based on its internal source
type during sql-to-rel conversion.
See FlinkCalciteCatalogReader.getTable(List)
for
details.
Constructor and Description |
---|
CatalogSchemaTable(ObjectIdentifier tableIdentifier,
CatalogManager.TableLookupResult lookupResult,
org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic,
boolean isStreaming)
Create a CatalogSchemaTable instance.
|
Modifier and Type | Method and Description |
---|---|
Optional<Catalog> |
getCatalog() |
ResolvedCatalogBaseTable<?> |
getResolvedCatalogTable() |
org.apache.calcite.rel.type.RelDataType |
getRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory) |
org.apache.flink.table.planner.plan.stats.FlinkStatistic |
getStatistic() |
String |
getSysEndFieldName() |
String |
getSysStartFieldName() |
ObjectIdentifier |
getTableIdentifier() |
boolean |
isStreamingMode() |
boolean |
isTemporary() |
getJdbcTableType, isRolledUp, rolledUpColumnValidInsideAgg, unwrap
public CatalogSchemaTable(ObjectIdentifier tableIdentifier, CatalogManager.TableLookupResult lookupResult, org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic, boolean isStreaming)
tableIdentifier
- Table identifierlookupResult
- A result of catalog lookupstatistic
- Table statisticsisStreaming
- If the table is for streaming modepublic ObjectIdentifier getTableIdentifier()
public ResolvedCatalogBaseTable<?> getResolvedCatalogTable()
public boolean isTemporary()
public boolean isStreamingMode()
public org.apache.calcite.rel.type.RelDataType getRowType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
getRowType
in interface org.apache.calcite.schema.Table
public org.apache.flink.table.planner.plan.stats.FlinkStatistic getStatistic()
getStatistic
in interface org.apache.calcite.schema.Table
getStatistic
in class org.apache.calcite.schema.impl.AbstractTable
public String getSysStartFieldName()
getSysStartFieldName
in interface org.apache.calcite.schema.TemporalTable
public String getSysEndFieldName()
getSysEndFieldName
in interface org.apache.calcite.schema.TemporalTable
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.