org.apache.beam.io.debezium

Class KafkaSourceConsumerFn.DebeziumSDFDatabaseHistory

java.lang.Object

io.debezium.relational.history.AbstractDatabaseHistory

org.apache.beam.io.debezium.KafkaSourceConsumerFn.DebeziumSDFDatabaseHistory

All Implemented Interfaces:

io.debezium.relational.history.DatabaseHistory

Enclosing class:

KafkaSourceConsumerFn<T>

public static class KafkaSourceConsumerFn.DebeziumSDFDatabaseHistory
extends io.debezium.relational.history.AbstractDatabaseHistory

Field Summary

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

config, logger

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

CONFIGURATION_FIELD_PREFIX_STRING, DDL_FILTER, NAME, SKIP_UNPARSEABLE_DDL_STATEMENTS, STORE_ONLY_MONITORED_TABLES_DDL

Constructor Summary

Constructors

Constructor and Description
DebeziumSDFDatabaseHistory()

Method Summary

Modifier and Type	Method and Description
boolean	exists()
protected void	recoverRecords(java.util.function.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.AbstractDatabaseHistory

configure, initializeStorage, record, record, recover, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

DebeziumSDFDatabaseHistory

public DebeziumSDFDatabaseHistory()

Method Detail

start

public void start()

Specified by:

start in interface io.debezium.relational.history.DatabaseHistory

Overrides:

start in class io.debezium.relational.history.AbstractDatabaseHistory

storeRecord

protected void storeRecord(io.debezium.relational.history.HistoryRecord record)
                    throws io.debezium.relational.history.DatabaseHistoryException

Specified by:

storeRecord in class io.debezium.relational.history.AbstractDatabaseHistory

Throws:

io.debezium.relational.history.DatabaseHistoryException

recoverRecords

protected void recoverRecords(java.util.function.Consumer<io.debezium.relational.history.HistoryRecord> consumer)

Specified by:

recoverRecords in class io.debezium.relational.history.AbstractDatabaseHistory

exists

public boolean exists()

storageExists

public boolean storageExists()