com.ververica.cdc.connectors.mysql

Class MySqlValidator

java.lang.Object

com.ververica.cdc.connectors.mysql.MySqlValidator

All Implemented Interfaces:

com.ververica.cdc.debezium.Validator, Serializable

public class MySqlValidator
extends Object
implements com.ververica.cdc.debezium.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 and Description
MySqlValidator(MySqlSourceConfig sourceConfig)
MySqlValidator(Properties dbzProperties)

Method Summary

Modifier and Type	Method and Description
void	validate()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.ververica.cdc.debezium.Validator

getDefaultValidator

Constructor Detail

MySqlValidator

public MySqlValidator(Properties dbzProperties)

MySqlValidator

public MySqlValidator(MySqlSourceConfig sourceConfig)

Method Detail

validate

public void validate()

Specified by:

validate in interface com.ververica.cdc.debezium.Validator