org.apache.flink.cdc.connectors.values

Class ValuesDatabase.ValuesMetadataAccessor

java.lang.Object

org.apache.flink.cdc.connectors.values.ValuesDatabase.ValuesMetadataAccessor

All Implemented Interfaces:

MetadataAccessor

Enclosing class:

ValuesDatabase

public static class ValuesDatabase.ValuesMetadataAccessor
extends Object
implements MetadataAccessor

provide namespace/schema/table lists for ValuesDataSource.

Constructor Summary

Constructors

Constructor and Description
ValuesMetadataAccessor()

Method Summary

Modifier and Type	Method and Description
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.

Methods inherited from class java.lang.Object

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

Constructor Detail

ValuesMetadataAccessor

public ValuesMetadataAccessor()

Method Detail

listNamespaces

public List<String> listNamespaces()
                            throws UnsupportedOperationException

Description copied from interface: MetadataAccessor

List all namespaces from external systems.

Specified by:

listNamespaces in interface MetadataAccessor

Returns:

The list of namespaces

Throws:

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

listSchemas

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

Description copied from interface: MetadataAccessor

List all schemas from external systems.

Specified by:

listSchemas in interface MetadataAccessor

Parameters:

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

Returns:

The list of schemas

Throws:

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

listTables

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

Description copied from interface: MetadataAccessor

List tables by namespace and schema from external systems.

Specified by:

listTables in interface MetadataAccessor

Parameters:

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.

Returns:

The list of TableIds.

getTableSchema

public Schema getTableSchema(TableId tableId)

Description copied from interface: MetadataAccessor

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.