com.ververica.cdc.debezium.utils

Class DatabaseHistoryUtil

java.lang.Object

com.ververica.cdc.debezium.utils.DatabaseHistoryUtil

public class DatabaseHistoryUtil
extends Object

Util to safely visit schema history between DatabaseHistory and DebeziumSourceFunction.

Method Summary

Modifier and Type	Method and Description
static void	registerHistory(String engineName, Collection<SchemaRecord> engineHistory) Registers history of schema safely.
static void	removeHistory(String engineName) Remove history of schema safely.
static Collection<SchemaRecord>	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).

Methods inherited from class java.lang.Object

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

Method Detail

registerHistory

public static void registerHistory(String engineName,
                                   Collection<SchemaRecord> engineHistory)

Registers history of schema safely.

removeHistory

public static void removeHistory(String engineName)

Remove history of schema safely.

retrieveHistory

public static Collection<SchemaRecord> 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). Returns null when the history of schema has been clean up.