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

Class PostgresDataSource.PostgresPipelineSource<T>

java.lang.Object

org.apache.flink.cdc.connectors.base.source.IncrementalSource<T,JdbcSourceConfig>

org.apache.flink.cdc.connectors.base.source.jdbc.JdbcIncrementalSource<T>

org.apache.flink.cdc.connectors.postgres.source.PostgresSourceBuilder.PostgresIncrementalSource<T>

org.apache.flink.cdc.connectors.postgres.source.PostgresDataSource.PostgresPipelineSource<T>

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.source.Source<T,SourceSplitBase,PendingSplitsState>, org.apache.flink.api.connector.source.SourceReaderFactory<T,SourceSplitBase>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>

Enclosing class:

PostgresDataSource

public static class PostgresDataSource.PostgresPipelineSource<T>
extends PostgresSourceBuilder.PostgresIncrementalSource<T>

The JdbcIncrementalSource implementation for Postgres.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.cdc.connectors.base.source.IncrementalSource

configFactory, deserializationSchema, offsetFactory, snapshotHooks, sourceSplitSerializer

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected org.apache.flink.connector.base.source.reader.RecordEmitter<SourceRecords,T,SourceSplitState>	createRecordEmitter(SourceConfig sourceConfig, SourceReaderMetrics sourceReaderMetrics)

Methods inherited from class org.apache.flink.cdc.connectors.postgres.source.PostgresSourceBuilder.PostgresIncrementalSource

builder, createEnumerator, createReader, restoreEnumerator

Methods inherited from class org.apache.flink.cdc.connectors.base.source.IncrementalSource

getBoundedness, getEnumeratorCheckpointSerializer, getProducedType, getSplitSerializer, setSnapshotHooks

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgresPipelineSource

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

Method Detail

createRecordEmitter

protected org.apache.flink.connector.base.source.reader.RecordEmitter<SourceRecords,T,SourceSplitState> createRecordEmitter(SourceConfig sourceConfig,
                                                                                                                                        SourceReaderMetrics sourceReaderMetrics)

Overrides:

createRecordEmitter in class PostgresSourceBuilder.PostgresIncrementalSource<T>