Package org.apache.beam.io.debezium

Class KafkaSourceConsumerFn.DebeziumSDFDatabaseHistory

java.lang.Object
io.debezium.relational.history.AbstractSchemaHistory
org.apache.beam.io.debezium.KafkaSourceConsumerFn.DebeziumSDFDatabaseHistory
All Implemented Interfaces:
io.debezium.relational.history.SchemaHistory
Enclosing class:
KafkaSourceConsumerFn<T>
public static class KafkaSourceConsumerFn.DebeziumSDFDatabaseHistory extends io.debezium.relational.history.AbstractSchemaHistory

  • Field Summary

    Fields inherited from class io.debezium.relational.history.AbstractSchemaHistory

    ALL_FIELDS, config, logger

    Fields inherited from interface io.debezium.relational.history.SchemaHistory

    CONFIGURATION_FIELD_PREFIX_STRING, DDL_FILTER, INTERNAL_CONNECTOR_CLASS, INTERNAL_CONNECTOR_ID, INTERNAL_PREFER_DDL, NAME, SKIP_UNPARSEABLE_DDL_STATEMENTS, STORE_ONLY_CAPTURED_DATABASES_DDL, STORE_ONLY_CAPTURED_TABLES_DDL

  • Constructor Summary

    Constructors
    Constructor
    Description
    DebeziumSDFDatabaseHistory()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    exists()
     
    protected void
    recoverRecords(Consumer<io.debezium.relational.history.HistoryRecord> consumer)
     
    void
    start()
     
    boolean
    storageExists()
     
    protected void
    storeRecord(io.debezium.relational.history.HistoryRecord record)
     

    Methods inherited from class io.debezium.relational.history.AbstractSchemaHistory

    configure, initializeStorage, record, record, recover, stop

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface io.debezium.relational.history.SchemaHistory

    recover, recover

  • Constructor Details

    • DebeziumSDFDatabaseHistory

      public DebeziumSDFDatabaseHistory()

  • Method Details

    • start

      public void start()
      Specified by:
      start in interface io.debezium.relational.history.SchemaHistory
      Overrides:
      start in class io.debezium.relational.history.AbstractSchemaHistory

    • storeRecord

      protected void storeRecord(io.debezium.relational.history.HistoryRecord record) throws io.debezium.relational.history.SchemaHistoryException
      Specified by:
      storeRecord in class io.debezium.relational.history.AbstractSchemaHistory
      Throws:
      io.debezium.relational.history.SchemaHistoryException

    • recoverRecords

      protected void recoverRecords(Consumer<io.debezium.relational.history.HistoryRecord> consumer)
      Specified by:
      recoverRecords in class io.debezium.relational.history.AbstractSchemaHistory

    • exists

      public boolean exists()

    • storageExists

      public boolean storageExists()