Package org.apache.flink.cdc.connectors.mysql.source

Class MySqlMetadataAccessor

java.lang.Object

org.apache.flink.cdc.connectors.mysql.source.MySqlMetadataAccessor

All Implemented Interfaces:

MetadataAccessor

@Internal
public class MySqlMetadataAccessor
extends Object
implements MetadataAccessor

MetadataAccessor for MySqlDataSource.

Constructor Summary

Constructors

Constructor	Description
MySqlMetadataAccessor(MySqlSourceConfig sourceConfig)

Method Summary

Modifier and Type	Method	Description
Schema	getTableSchema(TableId tableId)	Get the Schema of the given table.
List<String>	listNamespaces()	Always throw UnsupportedOperationException because MySQL does not support namespace.
List<String>	listSchemas(String namespace)	List all database from MySQL.
List<TableId>	listTables(String namespace, String dbName)	List tables from MySQL.

Methods inherited from class java.lang.Object

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

Constructor Detail

MySqlMetadataAccessor

public MySqlMetadataAccessor(MySqlSourceConfig sourceConfig)

Method Detail

listNamespaces

public List<String> listNamespaces()

Always throw UnsupportedOperationException because MySQL does not support namespace.

Specified by:

listNamespaces in interface MetadataAccessor

Returns:

The list of namespaces

listSchemas

public List<String> listSchemas(@Nullable
                                String namespace)

List all database from MySQL.

Specified by:

listSchemas in interface MetadataAccessor

Parameters:

namespace - This parameter is ignored because MySQL does not support namespace.

Returns:

The list of database

listTables

public List<TableId> listTables(@Nullable
                                String namespace,
                                @Nullable
                                String dbName)

List tables from MySQL.

Specified by:

listTables in interface MetadataAccessor

Parameters:

namespace - This parameter is ignored because MySQL does not support namespace.

dbName - The database to list tables from. If null, list tables from all databases.

Returns:

The list of TableIds.

getTableSchema

public Schema getTableSchema(TableId tableId)

Get the Schema of the given table.

Specified by:

getTableSchema in interface MetadataAccessor

Parameters:

tableId - The TableId of the given table.

Returns:

The Schema of the table.