Dump MySQL and parse immediately

Exec ddl statement, and persistent the schema info into storage

Initialize will be called at process start, you need to recover state from the point that checkpointed last time

Check whether the SQL statement is DDL, means not DML/DCL

IsIgnored tells whether this handler need to ignore the data of specified table

Load read data from storage, return nil data when read empty content and no error happened

LoadLastSnapshot will be called when schema tracker need to restore snapshot, as base data

New a schema tracker that can track DDL statements, making a schema mirror.

Persistent the schema info into storage. Before Persist is called, must ensure the binlog DML events previous is synced.

Register a hook that will be called before schema change

Register a hook that will be called before server_id change

Register a hook that will be called on DDL failed

Save syncs data into one of two file, alternately.

SaveSnapshot will be called when schema tracker decides to save a ddl statement

In some cloud MySQL, we have no privilege to use `--master-data`.

Clean any ckp in the o.ckps that is not in use

Init canal library, and start from min progress among all sinks

Init checkpoint manager, which saves binlog progress into to file or zookeeper

Init each sink, and register it into checkpoint manager, so that checkpoint manager will save sink's progress periodcally.

Make a sortable bytes slice, used as key of blotdb key-value

Return the bytes of protocol.Payload