Execute a SQL

You need to report error by this channel.

Use file&pos to compare, can not use gtid_set, because gtid_set may not contain each other

Exec ddl statement, but don't persistent the schema info

IsEventDuplicated tell whether this handler has received the event at sometime before

Reset will be called to get a empty storage

Save syncs data into storage

Load read data from all two files, and return newer one, return nil data when read empty content and no error happened.

Parse the dump data with Dumper generate. It can not parse all the data formats with mysqldump outputs

SaveSnapshot will be called when schema tracker decides to save a snapshot

`SetEventHandler` registers the sync handler, you must register your own handler before starting Canal.

Start will first try to dump all data from MySQL master `mysqldump`, then sync from the binlog position in the dump data. It will run forever until me

WaitUntil wait all sinks to reach a specified progress

doProduce send payload of bytes to kafka. If payload is too large to send, doProduce will make fragments, like IPv4 fragments.

unescapeString un-escapes the string. mysqldump will escape the string when dumps, Refer http://dev.mysql.com/doc/refman/5.7/en/string-literals.html

Parse CHANGE MASTER TO MASTER_LOG_FILE=name, MASTER_LOG_POS=pos;