Package org.apache.flink.cdc.connectors.mysql.debezium

Class EmbeddedFlinkDatabaseHistory

java.lang.Object

org.apache.flink.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory

All Implemented Interfaces:

io.debezium.relational.history.DatabaseHistory

public class EmbeddedFlinkDatabaseHistory
extends Object
implements io.debezium.relational.history.DatabaseHistory

A DatabaseHistory implementation which store the latest table schema in Flink state.

It stores/recovers history using data offered by MySqlSplitState.

Field Summary

Fields

Modifier and Type	Field	Description
static String	DATABASE_HISTORY_INSTANCE_NAME
static ConcurrentMap<String,Collection<io.debezium.relational.history.TableChanges.TableChange>>	TABLE_SCHEMAS

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

CONFIGURATION_FIELD_PREFIX_STRING, DDL_FILTER, NAME, SKIP_UNPARSEABLE_DDL_STATEMENTS, STORE_ONLY_CAPTURED_TABLES_DDL, STORE_ONLY_MONITORED_TABLES_DDL

Constructor Summary

Constructors

Constructor	Description
EmbeddedFlinkDatabaseHistory()

Method Summary

Modifier and Type	Method	Description
void	configure(io.debezium.config.Configuration config, io.debezium.relational.history.HistoryRecordComparator comparator, io.debezium.relational.history.DatabaseHistoryListener listener, boolean useCatalogBeforeSchema)
boolean	exists()
void	initializeStorage()
void	record(Map<String,?> source, Map<String,?> position, String databaseName, String ddl)
void	record(Map<String,?> source, Map<String,?> position, String databaseName, String schemaName, String ddl, io.debezium.relational.history.TableChanges changes)
void	recover(io.debezium.pipeline.spi.Offsets<?,?> offsets, io.debezium.relational.Tables schema, io.debezium.relational.ddl.DdlParser ddlParser)
void	recover(Map<Map<String,?>,Map<String,?>> offsets, io.debezium.relational.Tables schema, io.debezium.relational.ddl.DdlParser ddlParser)
static void	registerHistory(String engineName, Collection<io.debezium.relational.history.TableChanges.TableChange> engineHistory)
static Collection<io.debezium.relational.history.TableChanges.TableChange>	removeHistory(String engineName)
boolean	skipUnparseableDdlStatements()
void	start()
void	stop()
boolean	storageExists()
boolean	storeOnlyCapturedTables()

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.DatabaseHistory

recover

Field Detail

DATABASE_HISTORY_INSTANCE_NAME

public static final String DATABASE_HISTORY_INSTANCE_NAME

See Also:

Constant Field Values

TABLE_SCHEMAS

public static final ConcurrentMap<String,Collection<io.debezium.relational.history.TableChanges.TableChange>> TABLE_SCHEMAS

Constructor Detail

EmbeddedFlinkDatabaseHistory

public EmbeddedFlinkDatabaseHistory()

Method Detail

configure

public void configure(io.debezium.config.Configuration config,
                      io.debezium.relational.history.HistoryRecordComparator comparator,
                      io.debezium.relational.history.DatabaseHistoryListener listener,
                      boolean useCatalogBeforeSchema)

Specified by:

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

start

public void start()

Specified by:

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

record

public void record(Map<String,?> source,
                   Map<String,?> position,
                   String databaseName,
                   String ddl)
            throws io.debezium.relational.history.DatabaseHistoryException

Specified by:

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

Throws:

io.debezium.relational.history.DatabaseHistoryException

record

public void record(Map<String,?> source,
                   Map<String,?> position,
                   String databaseName,
                   String schemaName,
                   String ddl,
                   io.debezium.relational.history.TableChanges changes)
            throws io.debezium.relational.history.DatabaseHistoryException

Specified by:

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

Throws:

io.debezium.relational.history.DatabaseHistoryException

recover

public void recover(io.debezium.pipeline.spi.Offsets<?,?> offsets,
                    io.debezium.relational.Tables schema,
                    io.debezium.relational.ddl.DdlParser ddlParser)

Specified by:

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

recover

public void recover(Map<Map<String,?>,Map<String,?>> offsets,
                    io.debezium.relational.Tables schema,
                    io.debezium.relational.ddl.DdlParser ddlParser)

Specified by:

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

stop

public void stop()

Specified by:

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

exists

public boolean exists()

Specified by:

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

storageExists

public boolean storageExists()

Specified by:

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

initializeStorage

public void initializeStorage()

Specified by:

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

storeOnlyCapturedTables

public boolean storeOnlyCapturedTables()

Specified by:

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

skipUnparseableDdlStatements

public boolean skipUnparseableDdlStatements()

Specified by:

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

registerHistory

public static void registerHistory(String engineName,
                                   Collection<io.debezium.relational.history.TableChanges.TableChange> engineHistory)

removeHistory

public static Collection<io.debezium.relational.history.TableChanges.TableChange> removeHistory(String engineName)