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

Class TransformSchemaFactory

java.lang.Object

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

All Implemented Interfaces:

org.apache.calcite.schema.SchemaFactory

public class TransformSchemaFactory
extends Object
implements org.apache.calcite.schema.SchemaFactory

TransformSchemaFactory to generate the metadata of calcite.

Field Summary

Fields

Modifier and Type	Field	Description
static TransformSchemaFactory	INSTANCE

Method Summary

Modifier and Type	Method	Description
org.apache.calcite.schema.Schema	create(org.apache.calcite.schema.SchemaPlus schemaPlus, String schemaName, Map<String,Object> operand)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final TransformSchemaFactory INSTANCE

Method Detail

create

public org.apache.calcite.schema.Schema create(org.apache.calcite.schema.SchemaPlus schemaPlus,
                                               String schemaName,
                                               Map<String,Object> operand)

Specified by:

create in interface org.apache.calcite.schema.SchemaFactory