Package org.apache.flink.cdc.runtime.parser.metadata

Class TransformSchema

java.lang.Object

org.apache.calcite.schema.impl.AbstractSchema

org.apache.flink.cdc.runtime.parser.metadata.TransformSchema

All Implemented Interfaces:

org.apache.calcite.schema.Schema

public class TransformSchema
extends org.apache.calcite.schema.impl.AbstractSchema

TransformSchema to generate the metadata of calcite.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.calcite.schema.impl.AbstractSchema

org.apache.calcite.schema.impl.AbstractSchema.Factory

Nested classes/interfaces inherited from interface org.apache.calcite.schema.Schema

org.apache.calcite.schema.Schema.TableType

Constructor Summary

Constructors

Constructor	Description
TransformSchema(String name, List<TransformTable> tables)

Method Summary

Modifier and Type	Method	Description
Map<String,org.apache.calcite.schema.Table>	getTableMap()

Methods inherited from class org.apache.calcite.schema.impl.AbstractSchema

getExpression, getFunctionMultimap, getFunctionNames, getFunctions, getSubSchema, getSubSchemaMap, getSubSchemaNames, getTable, getTableNames, getType, getTypeMap, getTypeNames, isMutable, snapshot

Methods inherited from class java.lang.Object

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

Constructor Detail

TransformSchema

public TransformSchema(String name,
                       List<TransformTable> tables)

Method Detail

getTableMap

public Map<String,org.apache.calcite.schema.Table> getTableMap()

Overrides:

getTableMap in class org.apache.calcite.schema.impl.AbstractSchema