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

    checkStorageSettings, 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()