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

Class PostgresSourceFetchTaskContext

java.lang.Object

org.apache.flink.cdc.connectors.base.source.reader.external.JdbcSourceFetchTaskContext

org.apache.flink.cdc.connectors.postgres.source.fetch.PostgresSourceFetchTaskContext

All Implemented Interfaces:

FetchTask.Context

public class PostgresSourceFetchTaskContext
extends JdbcSourceFetchTaskContext

The context of PostgresScanFetchTask and PostgresStreamFetchTask.

Field Summary

Fields inherited from class org.apache.flink.cdc.connectors.base.source.reader.external.JdbcSourceFetchTaskContext

dataSourceDialect, dbzConnectorConfig, schemaNameAdjuster, sourceConfig

Constructor Summary

Constructors

Constructor	Description
PostgresSourceFetchTaskContext(JdbcSourceConfig sourceConfig, PostgresDialect dataSourceDialect)

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(SourceSplitBase sourceSplitBase)
PostgresConnection	getConnection()
io.debezium.connector.postgresql.PostgresSchema	getDatabaseSchema()
io.debezium.connector.postgresql.PostgresConnectorConfig	getDbzConnectorConfig()
io.debezium.pipeline.ErrorHandler	getErrorHandler()
io.debezium.connector.postgresql.PostgresEventDispatcher<io.debezium.relational.TableId>	getEventDispatcher()
io.debezium.connector.postgresql.PostgresOffsetContext	getOffsetContext()
io.debezium.connector.postgresql.PostgresPartition	getPartition()
String	getPluginName()
io.debezium.connector.base.ChangeEventQueue<io.debezium.pipeline.DataChangeEvent>	getQueue()
io.debezium.connector.postgresql.connection.ReplicationConnection	getReplicationConnection()
String	getSlotName()
io.debezium.pipeline.metrics.SnapshotChangeEventSourceMetrics<io.debezium.connector.postgresql.PostgresPartition>	getSnapshotChangeEventSourceMetrics()
io.debezium.connector.postgresql.spi.Snapshotter	getSnapShotter()
org.apache.flink.table.types.logical.RowType	getSplitType(io.debezium.relational.Table table)
Offset	getStreamOffset(org.apache.kafka.connect.source.SourceRecord sourceRecord)
io.debezium.relational.Tables.TableFilter	getTableFilter()
io.debezium.relational.TableId	getTableId(org.apache.kafka.connect.source.SourceRecord record)
io.debezium.connector.postgresql.PostgresTaskContext	getTaskContext()
WatermarkDispatcher	getWaterMarkDispatcher()
boolean	isDataChangeRecord(org.apache.kafka.connect.source.SourceRecord record)

Methods inherited from class org.apache.flink.cdc.connectors.base.source.reader.external.JdbcSourceFetchTaskContext

formatMessageTimestamp, getDataSourceDialect, getSchemaNameAdjuster, getSourceConfig, getSplitKey, isRecordBetween, rewriteOutputBuffer, setDbzConnectorConfig, supportsSplitKeyOptimization

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgresSourceFetchTaskContext

public PostgresSourceFetchTaskContext(JdbcSourceConfig sourceConfig,
                                      PostgresDialect dataSourceDialect)

Method Detail

getDbzConnectorConfig

public io.debezium.connector.postgresql.PostgresConnectorConfig getDbzConnectorConfig()

Overrides:

getDbzConnectorConfig in class JdbcSourceFetchTaskContext

configure

public void configure(SourceSplitBase sourceSplitBase)

getDatabaseSchema

public io.debezium.connector.postgresql.PostgresSchema getDatabaseSchema()

Specified by:

getDatabaseSchema in class JdbcSourceFetchTaskContext

getSplitType

public org.apache.flink.table.types.logical.RowType getSplitType(io.debezium.relational.Table table)

Specified by:

getSplitType in class JdbcSourceFetchTaskContext

getErrorHandler

public io.debezium.pipeline.ErrorHandler getErrorHandler()

Specified by:

getErrorHandler in class JdbcSourceFetchTaskContext

getEventDispatcher

public io.debezium.connector.postgresql.PostgresEventDispatcher<io.debezium.relational.TableId> getEventDispatcher()

Specified by:

getEventDispatcher in class JdbcSourceFetchTaskContext

getWaterMarkDispatcher

public WatermarkDispatcher getWaterMarkDispatcher()

Specified by:

getWaterMarkDispatcher in class JdbcSourceFetchTaskContext

getOffsetContext

public io.debezium.connector.postgresql.PostgresOffsetContext getOffsetContext()

Specified by:

getOffsetContext in class JdbcSourceFetchTaskContext

getPartition

public io.debezium.connector.postgresql.PostgresPartition getPartition()

Specified by:

getPartition in class JdbcSourceFetchTaskContext

getQueue

public io.debezium.connector.base.ChangeEventQueue<io.debezium.pipeline.DataChangeEvent> getQueue()

getTableFilter

public io.debezium.relational.Tables.TableFilter getTableFilter()

getTableId

public io.debezium.relational.TableId getTableId(org.apache.kafka.connect.source.SourceRecord record)

Specified by:

getTableId in interface FetchTask.Context

Overrides:

getTableId in class JdbcSourceFetchTaskContext

isDataChangeRecord

public boolean isDataChangeRecord(org.apache.kafka.connect.source.SourceRecord record)

Specified by:

isDataChangeRecord in interface FetchTask.Context

Overrides:

isDataChangeRecord in class JdbcSourceFetchTaskContext

getStreamOffset

public Offset getStreamOffset(org.apache.kafka.connect.source.SourceRecord sourceRecord)

close

public void close()
           throws Exception

Throws:

Exception

getConnection

public PostgresConnection getConnection()

getTaskContext

public io.debezium.connector.postgresql.PostgresTaskContext getTaskContext()

getReplicationConnection

public io.debezium.connector.postgresql.connection.ReplicationConnection getReplicationConnection()

getSnapshotChangeEventSourceMetrics

public io.debezium.pipeline.metrics.SnapshotChangeEventSourceMetrics<io.debezium.connector.postgresql.PostgresPartition> getSnapshotChangeEventSourceMetrics()

getSnapShotter

public io.debezium.connector.postgresql.spi.Snapshotter getSnapShotter()

getSlotName

public String getSlotName()

getPluginName

public String getPluginName()