Package org.apache.flink.table.factories

Class TableFactoryUtil

java.lang.Object

org.apache.flink.table.factories.TableFactoryUtil

@Deprecated
@Internal
public class TableFactoryUtil
extends Object

Deprecated.

Use FactoryUtil instead.

Utility for dealing with TableFactory using the TableFactoryService.

Constructor Summary

Constructors

Constructor	Description
TableFactoryUtil()	Deprecated.

Method Summary

Modifier and Type	Method	Description
static <T> org.apache.flink.table.legacy.sinks.TableSink<T>	findAndCreateTableSink(org.apache.flink.table.catalog.ObjectIdentifier objectIdentifier, org.apache.flink.table.catalog.CatalogTable catalogTable, org.apache.flink.configuration.ReadableConfig configuration, boolean isStreamingMode, boolean isTemporary)	Deprecated. Creates a TableSink from a CatalogTable.
static <T> org.apache.flink.table.legacy.sinks.TableSink<T>	findAndCreateTableSink(org.apache.flink.table.legacy.factories.TableSinkFactory.Context context)	Deprecated. Returns a table sink matching the context.
static <T> org.apache.flink.table.legacy.sources.TableSource<T>	findAndCreateTableSource(org.apache.flink.table.catalog.ObjectIdentifier objectIdentifier, org.apache.flink.table.catalog.CatalogTable catalogTable, org.apache.flink.configuration.ReadableConfig configuration, boolean isTemporary)	Deprecated. Creates a TableSource from a CatalogTable.
static <T> org.apache.flink.table.legacy.sources.TableSource<T>	findAndCreateTableSource(org.apache.flink.table.legacy.factories.TableSourceFactory.Context context)	Deprecated. Returns a table source matching the descriptor.
static List<CatalogModificationListener>	findCatalogModificationListenerList(org.apache.flink.configuration.ReadableConfig configuration, ClassLoader classLoader)	Deprecated. Find and create modification listener list from configuration.
static boolean	isLegacyConnectorOptions(org.apache.flink.configuration.ReadableConfig configuration, boolean isStreamingMode, org.apache.flink.table.catalog.ObjectIdentifier objectIdentifier, org.apache.flink.table.catalog.CatalogTable catalogTable, boolean isTemporary)	Deprecated. Checks whether the CatalogTable uses legacy connector sink options.

Methods inherited from class java.lang.Object

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

Constructor Detail

TableFactoryUtil

public TableFactoryUtil()

Deprecated.

Method Detail

findAndCreateTableSource

public static <T> org.apache.flink.table.legacy.sources.TableSource<T> findAndCreateTableSource(org.apache.flink.table.legacy.factories.TableSourceFactory.Context context)

Deprecated.

Returns a table source matching the descriptor.

findAndCreateTableSource

public static <T> org.apache.flink.table.legacy.sources.TableSource<T> findAndCreateTableSource(org.apache.flink.table.catalog.ObjectIdentifier objectIdentifier,
                                                                                                org.apache.flink.table.catalog.CatalogTable catalogTable,
                                                                                                org.apache.flink.configuration.ReadableConfig configuration,
                                                                                                boolean isTemporary)

Deprecated.

Creates a TableSource from a CatalogTable.

It considers Catalog.getFactory() if provided.

findAndCreateTableSink

public static <T> org.apache.flink.table.legacy.sinks.TableSink<T> findAndCreateTableSink(org.apache.flink.table.legacy.factories.TableSinkFactory.Context context)

Deprecated.

Returns a table sink matching the context.

findAndCreateTableSink

public static <T> org.apache.flink.table.legacy.sinks.TableSink<T> findAndCreateTableSink(org.apache.flink.table.catalog.ObjectIdentifier objectIdentifier,
                                                                                          org.apache.flink.table.catalog.CatalogTable catalogTable,
                                                                                          org.apache.flink.configuration.ReadableConfig configuration,
                                                                                          boolean isStreamingMode,
                                                                                          boolean isTemporary)

Deprecated.

Creates a TableSink from a CatalogTable.

It considers Catalog.getFactory() if provided.

isLegacyConnectorOptions

public static boolean isLegacyConnectorOptions(org.apache.flink.configuration.ReadableConfig configuration,
                                               boolean isStreamingMode,
                                               org.apache.flink.table.catalog.ObjectIdentifier objectIdentifier,
                                               org.apache.flink.table.catalog.CatalogTable catalogTable,
                                               boolean isTemporary)

Deprecated.

Checks whether the CatalogTable uses legacy connector sink options.

findCatalogModificationListenerList

public static List<CatalogModificationListener> findCatalogModificationListenerList(org.apache.flink.configuration.ReadableConfig configuration,
                                                                                    ClassLoader classLoader)

Deprecated.

Find and create modification listener list from configuration.