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

Class PostgresMetadataAccessor

java.lang.Object

org.apache.flink.cdc.connectors.postgres.source.PostgresMetadataAccessor

All Implemented Interfaces:

MetadataAccessor

@Internal
public class PostgresMetadataAccessor
extends Object
implements MetadataAccessor

MetadataAccessor for PostgresDataSource.

Constructor Summary

Constructors

Constructor	Description
PostgresMetadataAccessor(PostgresSourceConfig 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 postgres does not support namespace.
List<String>	listSchemas(String namespace)	List all database from postgres.
List<TableId>	listTables(String namespace, String dbName)	List tables from postgres.

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgresMetadataAccessor

public PostgresMetadataAccessor(PostgresSourceConfig sourceConfig)

Method Detail

listNamespaces

public List<String> listNamespaces()

Always throw UnsupportedOperationException because postgres 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 postgres.

Specified by:

listSchemas in interface MetadataAccessor

Parameters:

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

Returns:

The list of database

listTables

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

List tables from postgres.

Specified by:

listTables in interface MetadataAccessor

Parameters:

namespace - This parameter is ignored because postgres 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.