NewMySQLSink creates a new MySQL sink using schema storage.

NewSimpleMySQLSink creates a new simple MySQL Sink.

NewSyncPointStore creates a new SyncPoint sink with the sink-uri.

DefaultMaxTxnRow is the default max number of rows in a transaction.

DefaultWorkerCount is the default number of workers.

GetDBConnImpl is the implement holder to get db connection.

SyncPointStore is an abstraction for anything that a changefeed may emit into.