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

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.flink.cdc.connectors.base.source.reader.external.AbstractScanFetchTask (implements org.apache.flink.cdc.connectors.base.source.reader.external.FetchTask<Split>)
    • org.apache.flink.cdc.connectors.postgres.source.fetch.PostgresScanFetchTask
  • io.debezium.pipeline.source.AbstractSnapshotChangeEventSource<P,O> (implements io.debezium.pipeline.source.spi.SnapshotChangeEventSource<P,O>)
    • org.apache.flink.cdc.connectors.postgres.source.fetch.PostgresScanFetchTask.PostgresSnapshotSplitReadTask
  • io.debezium.pipeline.EventDispatcher<P,T> (implements java.lang.AutoCloseable)
    • io.debezium.connector.postgresql.PostgresEventDispatcher<T>
      • org.apache.flink.cdc.connectors.postgres.source.fetch.CDCPostgresDispatcher (implements org.apache.flink.cdc.connectors.postgres.source.schema.SchemaDispatcher, org.apache.flink.cdc.connectors.base.WatermarkDispatcher)
  • org.apache.flink.cdc.connectors.base.source.reader.external.JdbcSourceFetchTaskContext (implements org.apache.flink.cdc.connectors.base.source.reader.external.FetchTask.Context)
    • org.apache.flink.cdc.connectors.postgres.source.fetch.PostgresSourceFetchTaskContext
  • org.apache.flink.cdc.connectors.postgres.source.fetch.PostgresStreamFetchTask (implements org.apache.flink.cdc.connectors.base.source.reader.external.FetchTask<Split>)
  • io.debezium.connector.postgresql.PostgresStreamingChangeEventSource (implements io.debezium.pipeline.source.spi.StreamingChangeEventSource<P,O>)
    • org.apache.flink.cdc.connectors.postgres.source.fetch.PostgresStreamFetchTask.StreamSplitReadTask
  • org.apache.flink.cdc.connectors.postgres.source.fetch.StoppableChangeEventSourceContext (implements io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext)