Uses of Class
org.apache.flink.cdc.connectors.postgres.source.PostgresDialect

Packages that use PostgresDialect

Package	Description
org.apache.flink.cdc.connectors.postgres.source
org.apache.flink.cdc.connectors.postgres.source.enumerator
org.apache.flink.cdc.connectors.postgres.source.fetch
org.apache.flink.cdc.connectors.postgres.source.reader
org.apache.flink.cdc.connectors.postgres.utils

Uses of PostgresDialect in org.apache.flink.cdc.connectors.postgres.source

Constructors in org.apache.flink.cdc.connectors.postgres.source with parameters of type PostgresDialect

Constructor	Description
PostgresIncrementalSource(PostgresSourceConfigFactory configFactory, DebeziumDeserializationSchema<T> deserializationSchema, PostgresOffsetFactory offsetFactory, PostgresDialect dataSourceDialect)
PostgresPipelineSource(PostgresSourceConfigFactory configFactory, DebeziumDeserializationSchema<T> deserializationSchema, PostgresOffsetFactory offsetFactory, PostgresDialect dataSourceDialect, PostgresSourceConfig sourceConfig)

Uses of PostgresDialect in org.apache.flink.cdc.connectors.postgres.source.enumerator

Constructors in org.apache.flink.cdc.connectors.postgres.source.enumerator with parameters of type PostgresDialect

Constructor	Description
PostgresSourceEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SourceSplitBase> context, PostgresSourceConfig sourceConfig, SplitAssigner splitAssigner, PostgresDialect postgresDialect, org.apache.flink.api.connector.source.Boundedness boundedness)

Uses of PostgresDialect in org.apache.flink.cdc.connectors.postgres.source.fetch

Constructors in org.apache.flink.cdc.connectors.postgres.source.fetch with parameters of type PostgresDialect

Constructor	Description
PostgresSourceFetchTaskContext(JdbcSourceConfig sourceConfig, PostgresDialect dataSourceDialect)

Uses of PostgresDialect in org.apache.flink.cdc.connectors.postgres.source.reader

Constructors in org.apache.flink.cdc.connectors.postgres.source.reader with parameters of type PostgresDialect

Constructor	Description
PostgresPipelineRecordEmitter(DebeziumDeserializationSchema<T> debeziumDeserializationSchema, SourceReaderMetrics sourceReaderMetrics, PostgresSourceConfig sourceConfig, OffsetFactory offsetFactory, PostgresDialect postgresDialect)

Uses of PostgresDialect in org.apache.flink.cdc.connectors.postgres.utils

Methods in org.apache.flink.cdc.connectors.postgres.utils that return PostgresDialect

Modifier and Type	Method	Description
static PostgresDialect	PostgresSchemaUtils.getPostgresDialect(PostgresSourceConfig sourceConfig)