DatabaseHistoryUtil (flink-cdc-parent 3.8-SNAPSHOT API)

java.lang.Object
- org.apache.flink.cdc.debezium.utils.DatabaseHistoryUtil

```
public class DatabaseHistoryUtil
extends Object
```
Util to safely visit schema history between DatabaseHistory and DebeziumSourceFunction.

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method	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.