Package io.debezium.relational.history

Class MemorySchemaHistory

java.lang.Object

io.debezium.relational.history.AbstractSchemaHistory

io.debezium.relational.history.MemorySchemaHistory

All Implemented Interfaces:

SchemaHistory

@ThreadSafe
public final class MemorySchemaHistory
extends AbstractSchemaHistory

A SchemaHistory implementation that stores the schema history in memory.

Author:

Randall Hauch

Field Summary

Fields

Modifier and Type	Field	Description
private final io.debezium.util.FunctionalReadWriteLock	lock
private final List<HistoryRecord>	records

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
MemorySchemaHistory()	Create an instance that keeps the history in memory.

Method Summary

Modifier and Type	Method	Description
boolean	exists()	Determines if the database schema history entity exists; i.e. the storage must have been initialized and the history must have been populated.
protected void	recoverRecords(Consumer<HistoryRecord> records)
boolean	storageExists()	Determines if the underlying storage exists (e.g. a Kafka topic, file or similar).
protected void	storeRecord(HistoryRecord record)
String	toString()

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

configure, initializeStorage, record, record, recover, start, stop

Methods inherited from class java.lang.Object

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

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

checkStorageSettings, recover, recover, startBuffering, stopBuffering

Field Details

records

private final List<HistoryRecord> records

lock

private final io.debezium.util.FunctionalReadWriteLock lock

Constructor Details

MemorySchemaHistory

public MemorySchemaHistory()

Create an instance that keeps the history in memory.

Method Details

storeRecord

protected void storeRecord(HistoryRecord record)

Specified by:

storeRecord in class AbstractSchemaHistory

recoverRecords

protected void recoverRecords(Consumer<HistoryRecord> records)

Specified by:

recoverRecords in class AbstractSchemaHistory

storageExists

public boolean storageExists()

Description copied from interface: SchemaHistory

Determines if the underlying storage exists (e.g. a Kafka topic, file or similar). Note: storage may exist while history entities not yet written, see SchemaHistory.exists()

exists

public boolean exists()

Description copied from interface: SchemaHistory

Determines if the database schema history entity exists; i.e. the storage must have been initialized and the history must have been populated.

toString

public String toString()

Overrides:

toString in class Object