Package io.debezium.relational.history

Class AbstractFileBasedSchemaHistory

java.lang.Object

io.debezium.relational.history.AbstractSchemaHistory

io.debezium.relational.history.AbstractFileBasedSchemaHistory

All Implemented Interfaces:

SchemaHistory

public abstract class AbstractFileBasedSchemaHistory
extends AbstractSchemaHistory

Field Summary

Fields

Modifier and Type	Field	Description
protected final DocumentReader	documentReader
protected final DocumentWriter	documentWriter
protected final io.debezium.util.FunctionalReadWriteLock	lock
private static final org.slf4j.Logger	LOGGER
protected List<HistoryRecord>	records
protected final AtomicBoolean	running

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
AbstractFileBasedSchemaHistory()

Method Summary

Modifier and Type	Method	Description
protected void	doPreStart()
protected void	doPreStoreRecord(HistoryRecord record)
protected void	doStart()
protected void	doStop()
protected void	doStoreRecord(HistoryRecord record)
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 byte[]	fromHistoryRecord(HistoryRecord record)
protected List<HistoryRecord>	getRecords()
protected void	recoverRecords(Consumer<HistoryRecord> records)
void	start()	Start the history.
void	stop()	Stop recording history and release any resources acquired since SchemaHistory.configure(Configuration, HistoryRecordComparator, SchemaHistoryListener, boolean).
protected void	storeRecord(HistoryRecord record)
protected void	toHistoryRecord(InputStream inputStream)

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

configure, initializeStorage, record, record, recover

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, startBuffering, stopBuffering, storageExists

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

lock

protected final io.debezium.util.FunctionalReadWriteLock lock

running

protected final AtomicBoolean running

documentWriter

protected final DocumentWriter documentWriter

documentReader

protected final DocumentReader documentReader

records

protected volatile List<HistoryRecord> records

Constructor Details

AbstractFileBasedSchemaHistory

public AbstractFileBasedSchemaHistory()

Method Details

toHistoryRecord

protected void toHistoryRecord(InputStream inputStream)

fromHistoryRecord

protected byte[] fromHistoryRecord(HistoryRecord record)

getRecords

protected List<HistoryRecord> getRecords()

start

public void start()

Description copied from interface: SchemaHistory

Start the history.

Specified by:

start in interface SchemaHistory

Overrides:

start in class AbstractSchemaHistory

stop

public void stop()

Description copied from interface: SchemaHistory

Stop recording history and release any resources acquired since SchemaHistory.configure(Configuration, HistoryRecordComparator, SchemaHistoryListener, boolean).

Specified by:

stop in interface SchemaHistory

Overrides:

stop in class AbstractSchemaHistory

storeRecord

protected void storeRecord(HistoryRecord record)
                    throws SchemaHistoryException

Specified by:

storeRecord in class AbstractSchemaHistory

Throws:

SchemaHistoryException

recoverRecords

protected void recoverRecords(Consumer<HistoryRecord> records)

Specified by:

recoverRecords in class AbstractSchemaHistory

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.

doPreStart

protected void doPreStart()

doStart

protected void doStart()

doStop

protected void doStop()

doPreStoreRecord

protected void doPreStoreRecord(HistoryRecord record)

doStoreRecord

protected void doStoreRecord(HistoryRecord record)