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

Class PostgresDataSource

java.lang.Object

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

All Implemented Interfaces:

DataSource

@Internal
public class PostgresDataSource
extends Object
implements DataSource

A DataSource for Postgres cdc connector.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PostgresDataSource.PostgresPipelineSource<T>	The JdbcIncrementalSource implementation for Postgres.

Constructor Summary

Constructors

Constructor	Description
PostgresDataSource(PostgresSourceConfigFactory configFactory)
PostgresDataSource(PostgresSourceConfigFactory configFactory, List<PostgreSQLReadableMetadata> readableMetadataList)

Method Summary

Modifier and Type	Method	Description
EventSourceProvider	getEventSourceProvider()	Get the EventSourceProvider for reading events from external systems.
MetadataAccessor	getMetadataAccessor()	Get the MetadataAccessor for accessing metadata from external systems.
PostgresSourceConfig	getPostgresSourceConfig()
boolean	isParallelMetadataSource()	Indicating if this source may generate metadata events (SchemaChangeEvents) in parallel for each table.
SupportedMetadataColumn[]	supportedMetadataColumns()	Get the SupportedMetadataColumns of the source.

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgresDataSource

public PostgresDataSource(PostgresSourceConfigFactory configFactory)

PostgresDataSource

public PostgresDataSource(PostgresSourceConfigFactory configFactory,
                          List<PostgreSQLReadableMetadata> readableMetadataList)

Method Detail

getEventSourceProvider

public EventSourceProvider getEventSourceProvider()

Description copied from interface: DataSource

Get the EventSourceProvider for reading events from external systems.

Specified by:

getEventSourceProvider in interface DataSource

getMetadataAccessor

public MetadataAccessor getMetadataAccessor()

Description copied from interface: DataSource

Get the MetadataAccessor for accessing metadata from external systems.

Specified by:

getMetadataAccessor in interface DataSource

getPostgresSourceConfig

@VisibleForTesting
public PostgresSourceConfig getPostgresSourceConfig()

supportedMetadataColumns

public SupportedMetadataColumn[] supportedMetadataColumns()

Description copied from interface: DataSource

Get the SupportedMetadataColumns of the source.

Specified by:

supportedMetadataColumns in interface DataSource

isParallelMetadataSource

public boolean isParallelMetadataSource()

Description copied from interface: DataSource

Indicating if this source may generate metadata events (SchemaChangeEvents) in parallel for each table. If returns false, you'll get a regular operator topology that is compatible with single-incremented sources like MySQL. Returns true for sources that does not maintain a globally sequential schema change events stream, like MongoDB or Kafka.
Note that new topology still an experimental feature. Return false by default to avoid unexpected behaviors.

Specified by:

isParallelMetadataSource in interface DataSource