org.apache.paimon.flink

Class FlinkTableFactory

java.lang.Object

org.apache.paimon.flink.AbstractFlinkTableFactory

org.apache.paimon.flink.FlinkTableFactory

All Implemented Interfaces:

org.apache.flink.table.factories.DynamicTableFactory, org.apache.flink.table.factories.DynamicTableSinkFactory, org.apache.flink.table.factories.DynamicTableSourceFactory, org.apache.flink.table.factories.Factory

public class FlinkTableFactory
extends AbstractFlinkTableFactory

A paimon DynamicTableFactory to create source and sink.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.factories.DynamicTableFactory

org.apache.flink.table.factories.DynamicTableFactory.Context

Constructor Summary

Constructors

Constructor and Description
FlinkTableFactory()
FlinkTableFactory(FlinkCatalog flinkCatalog)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.table.connector.sink.DynamicTableSink	createDynamicTableSink(org.apache.flink.table.factories.DynamicTableFactory.Context context)
org.apache.flink.table.connector.source.DynamicTableSource	createDynamicTableSource(org.apache.flink.table.factories.DynamicTableFactory.Context context)
String	factoryIdentifier()

Methods inherited from class org.apache.paimon.flink.AbstractFlinkTableFactory

createOptionalLogStoreFactory, optionalOptions, requiredOptions

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.factories.DynamicTableFactory

forwardOptions

Constructor Detail

FlinkTableFactory

public FlinkTableFactory()

FlinkTableFactory

public FlinkTableFactory(@Nullable
                         FlinkCatalog flinkCatalog)

Method Detail

factoryIdentifier

public String factoryIdentifier()

createDynamicTableSource

public org.apache.flink.table.connector.source.DynamicTableSource createDynamicTableSource(org.apache.flink.table.factories.DynamicTableFactory.Context context)

Specified by:

createDynamicTableSource in interface org.apache.flink.table.factories.DynamicTableSourceFactory

Overrides:

createDynamicTableSource in class AbstractFlinkTableFactory

createDynamicTableSink

public org.apache.flink.table.connector.sink.DynamicTableSink createDynamicTableSink(org.apache.flink.table.factories.DynamicTableFactory.Context context)

Specified by:

createDynamicTableSink in interface org.apache.flink.table.factories.DynamicTableSinkFactory

Overrides:

createDynamicTableSink in class AbstractFlinkTableFactory