Package io.debezium.connector.postgresql

Class PostgresStreamingChangeEventSource

java.lang.Object

io.debezium.connector.postgresql.PostgresStreamingChangeEventSource

All Implemented Interfaces:

io.debezium.pipeline.source.spi.ChangeEventSource, io.debezium.pipeline.source.spi.StreamingChangeEventSource<io.debezium.connector.postgresql.PostgresPartition,io.debezium.connector.postgresql.PostgresOffsetContext>

Direct Known Subclasses:

PostgresStreamFetchTask.StreamSplitReadTask

public class PostgresStreamingChangeEventSource
extends Object
implements io.debezium.pipeline.source.spi.StreamingChangeEventSource<io.debezium.connector.postgresql.PostgresPartition,io.debezium.connector.postgresql.PostgresOffsetContext>

Copied from Debezium 1.9.8.final

Line 150~151 : set the ending lsn for the replication connection.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	PostgresStreamingChangeEventSource.PgConnectionSupplier

Nested classes/interfaces inherited from interface io.debezium.pipeline.source.spi.ChangeEventSource

io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext

Constructor Summary

Constructors

Constructor

Description

PostgresStreamingChangeEventSource(io.debezium.connector.postgresql.PostgresConnectorConfig connectorConfig, io.debezium.connector.postgresql.spi.Snapshotter snapshotter, PostgresConnection connection, io.debezium.connector.postgresql.PostgresEventDispatcher<io.debezium.relational.TableId> dispatcher, io.debezium.pipeline.ErrorHandler errorHandler, io.debezium.util.Clock clock, io.debezium.connector.postgresql.PostgresSchema schema, io.debezium.connector.postgresql.PostgresTaskContext taskContext, io.debezium.connector.postgresql.connection.ReplicationConnection replicationConnection)

Method Summary

Modifier and Type	Method	Description
void	commitOffset(Map<String,?> offset)
void	execute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, io.debezium.connector.postgresql.PostgresPartition partition, io.debezium.connector.postgresql.PostgresOffsetContext offsetContext)
void	init()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.debezium.pipeline.source.spi.StreamingChangeEventSource

executeIteration

Constructor Detail

PostgresStreamingChangeEventSource

public PostgresStreamingChangeEventSource(io.debezium.connector.postgresql.PostgresConnectorConfig connectorConfig,
                                          io.debezium.connector.postgresql.spi.Snapshotter snapshotter,
                                          PostgresConnection connection,
                                          io.debezium.connector.postgresql.PostgresEventDispatcher<io.debezium.relational.TableId> dispatcher,
                                          io.debezium.pipeline.ErrorHandler errorHandler,
                                          io.debezium.util.Clock clock,
                                          io.debezium.connector.postgresql.PostgresSchema schema,
                                          io.debezium.connector.postgresql.PostgresTaskContext taskContext,
                                          io.debezium.connector.postgresql.connection.ReplicationConnection replicationConnection)

Method Detail

init

public void init()

Specified by:

init in interface io.debezium.pipeline.source.spi.StreamingChangeEventSource<io.debezium.connector.postgresql.PostgresPartition,io.debezium.connector.postgresql.PostgresOffsetContext>

execute

public void execute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context,
                    io.debezium.connector.postgresql.PostgresPartition partition,
                    io.debezium.connector.postgresql.PostgresOffsetContext offsetContext)
             throws InterruptedException

Specified by:

execute in interface io.debezium.pipeline.source.spi.StreamingChangeEventSource<io.debezium.connector.postgresql.PostgresPartition,io.debezium.connector.postgresql.PostgresOffsetContext>

Throws:

InterruptedException

commitOffset

public void commitOffset(Map<String,?> offset)

Specified by:

commitOffset in interface io.debezium.pipeline.source.spi.StreamingChangeEventSource<io.debezium.connector.postgresql.PostgresPartition,io.debezium.connector.postgresql.PostgresOffsetContext>