code: func SetDDLBinlog(client *pumpcli.PumpsClient, txn kv.Transaction, jobID int64, ddlQuery string) {
  	if client == nil {
  		return
  	}
  
  	ddlQuery = addSpecialComment(ddlQuery)
  	info := &BinlogInfo{
  		Data: &binlog.Binlog{
  			Tp:       binlog.BinlogType_Prewrite,
  			DdlJobId: jobID,
  			DdlQuery: []byte(ddlQuery),
  		},
  		Client: client,
  	}
  	txn.SetOption(kv.BinlogInfo, info)
  }
docs: // SetDDLBinlog sets DDL binlog in the kv.Transaction.