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

Class FlussMetadataAccessor

java.lang.Object

org.apache.flink.cdc.connectors.fluss.source.FlussMetadataAccessor

All Implemented Interfaces:

MetadataAccessor

public class FlussMetadataAccessor
extends Object
implements MetadataAccessor

A MetadataAccessor implementation that uses the Fluss Admin API to list databases, tables, and retrieve table schemas from a Fluss cluster.

Constructor Summary

Constructors

Constructor	Description
FlussMetadataAccessor(org.apache.fluss.config.Configuration flussConfig)

Method Summary

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

FlussMetadataAccessor

public FlussMetadataAccessor(org.apache.fluss.config.Configuration flussConfig)

Method Detail

listNamespaces

public List<String> listNamespaces()

Description copied from interface: MetadataAccessor

List all namespaces from external systems.

Specified by:

listNamespaces in interface MetadataAccessor

Returns:

The list of namespaces

listSchemas

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

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

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.