org.apache.flink.cdc.common.source

接口 MetadataAccessor

@PublicEvolving
public interface MetadataAccessor

MetadataAccessor is used by DataSource to access the metadata from external systems.

方法概要

限定符和类型	方法和说明
Schema	getTableSchema(TableId tableId) Get the Schema of the given table.
List<String>	listNamespaces() List all namespaces from external systems.
List<String>	listSchemas(String namespace) List all schemas from external systems.
List<TableId>	listTables(String namespace, String schemaName) List tables by namespace and schema from external systems.

方法详细资料

listNamespaces

List<String> listNamespaces()

List all namespaces from external systems.

返回:

The list of namespaces

抛出:

UnsupportedOperationException - Thrown, if the external system does not support namespace.

listSchemas

List<String> listSchemas(@Nullable
                         String namespace)

List all schemas from external systems.

参数:

namespace - The namespace to list schemas from. If null, list schemas from all namespaces.

返回:

The list of schemas

抛出:

UnsupportedOperationException - Thrown, if the external system does not support schema.

listTables

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

List tables by namespace and schema from external systems.

参数:

namespace - The namespace to list tables from. If null, list tables from all namespaces.

schemaName - The schema to list tables from. If null, list tables from all schemas.

返回:

The list of TableIds.

getTableSchema

Schema getTableSchema(TableId tableId)

Get the Schema of the given table.

参数:

tableId - The TableId of the given table.

返回:

The Schema of the table.