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

Class PostgresSourceBuilder.PostgresIncrementalSource<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>

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>

Direct Known Subclasses:

PostgresDataSource.PostgresPipelineSource

Enclosing class:

PostgresSourceBuilder<T>

@Experimental
public static class PostgresSourceBuilder.PostgresIncrementalSource<T>
extends JdbcIncrementalSource<T>

The Postgres source based on the incremental snapshot framework.

See Also:

Serialized Form

Field Summary

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

configFactory, dataSourceDialect, deserializationSchema, offsetFactory, snapshotHooks, sourceSplitSerializer

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
static <T> PostgresSourceBuilder<T>	builder()
PostgresSourceEnumerator	createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SourceSplitBase> enumContext)
PostgresSourceReader	createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)
protected org.apache.flink.connector.base.source.reader.RecordEmitter<SourceRecords,T,SourceSplitState>	createRecordEmitter(SourceConfig sourceConfig, SourceReaderMetrics sourceReaderMetrics)
PostgresSourceEnumerator	restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SourceSplitBase> enumContext, PendingSplitsState checkpoint)

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

PostgresIncrementalSource

public PostgresIncrementalSource(PostgresSourceConfigFactory configFactory,
                                 DebeziumDeserializationSchema<T> deserializationSchema,
                                 PostgresOffsetFactory offsetFactory,
                                 PostgresDialect dataSourceDialect)

Method Detail

createEnumerator

public PostgresSourceEnumerator createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SourceSplitBase> enumContext)

Specified by:

createEnumerator in interface org.apache.flink.api.connector.source.Source<T,SourceSplitBase,PendingSplitsState>

Overrides:

createEnumerator in class IncrementalSource<T,JdbcSourceConfig>

restoreEnumerator

public PostgresSourceEnumerator restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SourceSplitBase> enumContext,
                                                  PendingSplitsState checkpoint)

Specified by:

restoreEnumerator in interface org.apache.flink.api.connector.source.Source<T,SourceSplitBase,PendingSplitsState>

Overrides:

restoreEnumerator in class IncrementalSource<T,JdbcSourceConfig>

createReader

public PostgresSourceReader createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)
                                  throws Exception

Specified by:

createReader in interface org.apache.flink.api.connector.source.SourceReaderFactory<T,SourceSplitBase>

Overrides:

createReader in class IncrementalSource<T,JdbcSourceConfig>

Throws:

Exception

createRecordEmitter

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

Overrides:

createRecordEmitter in class IncrementalSource<T,JdbcSourceConfig>

builder

public static <T> PostgresSourceBuilder<T> builder()