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

java.lang.Object
- org.apache.flink.cdc.connectors.mysql.MySqlValidator

All Implemented Interfaces:

Serializable, Validator
```
public class MySqlValidator
extends Object
implements Validator
```
The validator for MySql: it only cares about the version of the database is larger than or equal to 5.7. It also requires the binlog format in the database is ROW and row image is FULL.

See Also:

Serialized Form

- Constructor Summary
  
  Constructors
  Constructor Description
  
  MySqlValidator(Properties dbzProperties)
  
  MySqlValidator(MySqlSourceConfig sourceConfig)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  void validate()
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MySqlValidator

public MySqlValidator(Properties dbzProperties)

MySqlValidator

public MySqlValidator(MySqlSourceConfig sourceConfig)

Method Detail
- validate
```
public void validate()
```
  Specified by:
  
  validate in interface Validator