Uses of Class
com.ververica.cdc.debezium.internal.SchemaRecord

Packages that use SchemaRecord

Package	Description
com.ververica.cdc.debezium.internal
com.ververica.cdc.debezium.utils

Uses of SchemaRecord in com.ververica.cdc.debezium.internal

Method parameters in com.ververica.cdc.debezium.internal with type arguments of type SchemaRecord

Modifier and Type	Method and Description
static boolean	FlinkDatabaseSchemaHistory.isCompatible(Collection<SchemaRecord> records) Determine whether the FlinkDatabaseSchemaHistory is compatible with the specified state.
static boolean	FlinkDatabaseHistory.isCompatible(Collection<SchemaRecord> records) Determine whether the FlinkDatabaseHistory is compatible with the specified state.

Uses of SchemaRecord in com.ververica.cdc.debezium.utils

Methods in com.ververica.cdc.debezium.utils that return types with arguments of type SchemaRecord

Modifier and Type	Method and Description
static Collection<SchemaRecord>	DatabaseHistoryUtil.retrieveHistory(String engineName) Retrieves history of schema safely, this method firstly checks the history status of specific engine, and then return the history of schema if the history exists(didn't clean up yet).

Method parameters in com.ververica.cdc.debezium.utils with type arguments of type SchemaRecord

Modifier and Type	Method and Description
static void	DatabaseHistoryUtil.registerHistory(String engineName, Collection<SchemaRecord> engineHistory) Registers history of schema safely.