Package io.debezium.schema

Interface HistorizedDatabaseSchema<I extends io.debezium.spi.schema.DataCollectionId>

Type Parameters:

I - The collection id type of this schema

All Superinterfaces:

AutoCloseable, DatabaseSchema<I>

All Known Implementing Classes:

HistorizedRelationalDatabaseSchema

public interface HistorizedDatabaseSchema<I extends io.debezium.spi.schema.DataCollectionId>
extends DatabaseSchema<I>

A database schema that is historized, i.e. it undergoes schema changes and can be recovered from a persistent schema history.

Author:

Gunnar Morling

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	HistorizedDatabaseSchema.SchemaChangeEventConsumer

Field Summary

Fields inherited from interface io.debezium.schema.DatabaseSchema

NO_CAPTURED_DATA_COLLECTIONS_WARNING

Method Summary

Modifier and Type	Method	Description
void	applySchemaChange(SchemaChangeEvent schemaChange)
Predicate<String>	ddlFilter()
SchemaHistory	getSchemaHistory()
void	initializeStorage()
void	recover(Offsets<?,?> offsets)
default void	recover(Partition partition, OffsetContext offset)
boolean	skipUnparseableDdlStatements()
boolean	storeOnlyCapturedDatabases()
boolean	storeOnlyCapturedTables()

Methods inherited from interface java.lang.AutoCloseable

close

Methods inherited from interface io.debezium.schema.DatabaseSchema

assureNonEmptySchema, dataCollectionIds, isHistorized, schemaFor, tableInformationComplete

Method Details

applySchemaChange

void applySchemaChange(SchemaChangeEvent schemaChange)

recover

default void recover(Partition partition,
 OffsetContext offset)
              throws InterruptedException

Throws:

InterruptedException

recover

void recover(Offsets<?,?> offsets)
      throws InterruptedException

Throws:

InterruptedException

initializeStorage

void initializeStorage()

ddlFilter

Predicate<String> ddlFilter()

skipUnparseableDdlStatements

boolean skipUnparseableDdlStatements()

storeOnlyCapturedTables

boolean storeOnlyCapturedTables()

storeOnlyCapturedDatabases

boolean storeOnlyCapturedDatabases()

getSchemaHistory

SchemaHistory getSchemaHistory()