Package org.apache.flink.table.factories

Interface ManagedTableFactory

All Superinterfaces:

DynamicTableFactory, Factory

@Deprecated
@Internal
public interface ManagedTableFactory
extends DynamicTableFactory

Deprecated.

This interface will be removed soon. Please see FLIP-346 for more details.

Base interface for configuring a managed dynamic table connector. The managed table factory is used when there is no FactoryUtil.CONNECTOR option.

Nested Class Summary

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

DynamicTableFactory.Context

Field Summary

Fields

Modifier and Type	Field	Description
static String	DEFAULT_IDENTIFIER	Deprecated. factoryIdentifier() for the managed table factory.

Method Summary

Modifier and Type	Method	Description
static ManagedTableFactory	discoverManagedTableFactory(ClassLoader classLoader)	Deprecated. Discovers the unique implementation of ManagedTableFactory without identifier.
Map<String,String>	enrichOptions(DynamicTableFactory.Context context)	Deprecated. Enrich options from catalog and session information.
default String	factoryIdentifier()	Deprecated. Returns a unique identifier among same factory interfaces.
Map<String,String>	onCompactTable(DynamicTableFactory.Context context, CatalogPartitionSpec partitionSpec)	Deprecated. Notifies the listener that a table compaction occurred.
void	onCreateTable(DynamicTableFactory.Context context, boolean ignoreIfExists)	Deprecated. Notifies the listener that a table creation occurred.
void	onDropTable(DynamicTableFactory.Context context, boolean ignoreIfNotExists)	Deprecated. Notifies the listener that a table drop occurred.

Methods inherited from interface org.apache.flink.table.factories.DynamicTableFactory

forwardOptions

Methods inherited from interface org.apache.flink.table.factories.Factory

optionalOptions, requiredOptions

Field Detail

DEFAULT_IDENTIFIER

static final String DEFAULT_IDENTIFIER

Deprecated.

factoryIdentifier() for the managed table factory.

See Also:

Constant Field Values

Method Detail

factoryIdentifier

default String factoryIdentifier()

Deprecated.

Description copied from interface: Factory

Returns a unique identifier among same factory interfaces.

For consistency, an identifier should be declared as one lower case word (e.g. kafka). If multiple factories exist for different versions, a version should be appended using "-" (e.g. elasticsearch-7).

Specified by:

factoryIdentifier in interface Factory

enrichOptions

Map<String,String> enrichOptions(DynamicTableFactory.Context context)

Deprecated.

Enrich options from catalog and session information.

Returns:

new options of this table.

onCreateTable

void onCreateTable(DynamicTableFactory.Context context,
                   boolean ignoreIfExists)

Deprecated.

Notifies the listener that a table creation occurred.

onDropTable

void onDropTable(DynamicTableFactory.Context context,
                 boolean ignoreIfNotExists)

Deprecated.

Notifies the listener that a table drop occurred.

onCompactTable

Map<String,String> onCompactTable(DynamicTableFactory.Context context,
                                        CatalogPartitionSpec partitionSpec)

Deprecated.

Notifies the listener that a table compaction occurred.

Returns:

dynamic options of the source and sink info for this table.

discoverManagedTableFactory

static ManagedTableFactory discoverManagedTableFactory(ClassLoader classLoader)

Deprecated.

Discovers the unique implementation of ManagedTableFactory without identifier.