MaxCompute MCQA2.0功能提供如下能力：

• 支持對中小數(shù)據(jù)量（百GB規(guī)模內(nèi)）查詢作業(yè)、數(shù)據(jù)插入作業(yè)進(jìn)行加速優(yōu)化，最快執(zhí)行時(shí)間為亞秒級(jí)。

• 完全兼容MaxCompute的SQL功能，包括UDF、Delta Table、增量物化視圖特性等。

• 支持隔離的查詢加速資源池，獨(dú)享服務(wù)于本租戶，穩(wěn)定性更高。

• 支持自定義查詢加速資源池和批處理資源池的分時(shí)資源分配規(guī)則，提高資源整體利用率。

• 支持全鏈路Cache，作業(yè)會(huì)自動(dòng)將多個(gè)環(huán)節(jié)的執(zhí)行結(jié)果寫入臨時(shí)緩存，后續(xù)執(zhí)行的作業(yè)在全鏈路的多個(gè)環(huán)節(jié)都可能命中Cache，加快執(zhí)行速度。

使用MCQA2.0功能進(jìn)行DataWorksIDE臨時(shí)查詢或數(shù)據(jù)開發(fā)

在DataWorks數(shù)據(jù)開發(fā)（新版）頁面新建MaxCompute SQL節(jié)點(diǎn)后，在右側(cè)的調(diào)試配置面板中可以選擇計(jì)算配額，選擇交互式配額組以后，數(shù)據(jù)開發(fā)（新版）頁面執(zhí)行的作業(yè)將會(huì)被調(diào)度到交互式配額組執(zhí)行。如果返回結(jié)果的InstanceId帶有_mcqa的后綴，則代表成功運(yùn)行到了MCQA2.0模式。

使用MCQA2.0功能進(jìn)行MaxCompute控制臺(tái)TopConsolo-SQL分析

MaxCompute控制臺(tái)SQL分析頁面右側(cè)的運(yùn)行參數(shù)可以選擇計(jì)算配額，選擇交互式配額組以后，SQL分析頁面執(zhí)行的作業(yè)將會(huì)被調(diào)度到交互式配額組執(zhí)行。如果返回結(jié)果的InstanceId帶有_mcqa的后綴，則代表成功運(yùn)行到了MCQA2.0模式。

通過JDBC使用MCQA2.0功能

您可以通過以下操作開啟MCQA2.0功能，并使用JDBC連接MaxCompute，詳情請參見使用說明。

1. 下載支持MCQA2.0功能的JDBC JAR包或可編譯的源代碼。

2. 通過Maven方式配置Pom依賴。

   說明

   此處以3.8.0-rc0版本為例配置Pom依賴，您可根據(jù)實(shí)際自行選擇3.8.0-rc0或以上版本，推薦使用最新版本。

   <dependency>
       <groupId>com.aliyun.odps</groupId>
       <artifactId>odps-jdbc</artifactId>
       <version>3.8.0-rc0</version>
   </dependency>

3. 基于源代碼創(chuàng)建Java程序，適配實(shí)際信息，詳情請參見MaxCompute JDBC，示例如下。

   // 阿里云賬號(hào)AccessKey擁有所有API的訪問權(quán)限，風(fēng)險(xiǎn)很高。強(qiáng)烈建議您創(chuàng)建并使用RAM用戶進(jìn)行API訪問或日常運(yùn)維，請登錄RAM控制臺(tái)創(chuàng)建RAM用戶
   // 此處以把AccessKey 和 AccessKeySecret 保存在環(huán)境變量為例說明。您也可以根據(jù)業(yè)務(wù)需要，保存到配置文件里
   // 強(qiáng)烈建議不要把 AccessKey 和 AccessKeySecret 保存到代碼里，會(huì)存在密鑰泄漏風(fēng)險(xiǎn)
   private static String accessId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
   private static String accessKey = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
   //your_project_name為需要使用MCQA功能的項(xiàng)目名稱。
   //your_quota_nick_name為期望使用的交互式Quota組的名字
   String conn = "jdbc:odps:http://service.<regionid>.maxcompute.aliyun.com/api?project=<YOUR_PROJECT_NAME>"&accessId&accessKey&charset=UTF-8&interactiveMode=true&quotaName=<your_quota_nick_name>&autoSelectLimit=1000000000";
   Statement stmt = conn.createStatement();
   Connection conn = DriverManager.getConnection(conn, accessId, accessKey);
   Statement stmt = conn.createStatement();
   String tableName = "testOdpsDriverTable";
   stmt.execute("DROP TABLE IF EXISTS " + tableName);
   stmt.execute("CREATE TABLE " + tableName + " (key int, value string)");

   您也可以在連接串中配置如下參數(shù)，完善處理邏輯。

   參數(shù)	說明
   enableOdpsLogger	用于打印日志。未配置SLF4J時(shí)，建議您將此參數(shù)配置為True。

使用示例

以下為您展示在Tableau和SQLWorkbench中使用MCQA2.0時(shí)的服務(wù)器配置方法。

• 示例1：Tableau使用MCQA2.0

  服務(wù)器增加interactiveMode=true和quotaName=your_quota_nick_name屬性，用于開啟MCQA2.0功能。建議您同步增加enableOdpsLogger=true屬性，用于打印日志。配置操作詳情請參見配置JDBC使用Tableau。

  完整的服務(wù)器配置示例如下。

  // <your_quota_nick_name>為期望使用的交互式Quota組的名字
  http://service.cn-beijing.maxcompute.aliyun.com/api?
  project=****_beijing&interactiveMode=true&quotaName=<your_quota_nick_name>&enableOdpsLogger=true&autoSelectLimit=1000000000"

  如果只對項(xiàng)目空間中的部分表進(jìn)行Tableau操作，您可以在服務(wù)器參數(shù)中增加table_list=table_name1, table_name2屬性選擇需要的表，多表之間用半角逗號(hào)（,）分隔。如果表過多，會(huì)導(dǎo)致Tableau打開緩慢，強(qiáng)烈建議使用此方式只載入需要的表。

  示例如下，對于有大量分區(qū)的表不建議將所有分區(qū)的數(shù)據(jù)都設(shè)置成數(shù)據(jù)源，可以篩選需要的分區(qū)或通過自定義SQL獲取需要的數(shù)據(jù)。

  //your_quota_nick_name為期望使用的交互式 Quota 組的名字
  http://service.cn-beijing.maxcompute.aliyun.com/api?project=****_beijing
  &interactiveMode=true&alwaysFallback=true&quotaName=<YOUR_QUOTA_NICK_NAME>&enableOdpsLogger=true&autoSelectLimit=1000000000"
  &table_list=orders,customers

• 示例2：SQLWorkBench使用MCQA2.0

  完成JDBC驅(qū)動(dòng)配置后，在Profile配置界面修改已填寫的JDBC URL，支持SQLWorkbench使用MCQA2.0功能。Profile配置操作詳情請參見配置JDBC使用SQL Workbench/J。

  需要配置的URL格式如下所示：

  //your_quota_nick_name為期望使用的交互式 Quota 組的名字
  jdbc:odps:<MaxCompute_endpoint>?
  project=<MaxCompute_project_name>&accessId=<AccessKey ID>&accessKey=<AccessKey Secret>
  &charset=UTF-8&interactiveMode=true&quotaName=<YOUR_QUOTA_NICK_NAME>&autoSelectLimit=1000000000"

  參數(shù)說明如下。

  參數(shù)	說明
  MaxCompute_endpoint	MaxCompute服務(wù)所在區(qū)域的Endpoint，詳情請參見Endpoint。
  MaxCompute_project_name	MaxCompute項(xiàng)目空間名稱。
  AccessKey ID	有訪問指定項(xiàng)目空間權(quán)限的AccessKey ID。 您可以進(jìn)入AccessKey管理頁面獲取AccessKey ID。
  AccessKey Secret	AccessKey ID對應(yīng)的AccessKey Secret。 您可以進(jìn)入AccessKey管理頁面獲取AccessKey Secret。
  your_quota_nick_name	期望使用的交互式Quota組的名稱。
  charset=UTF-8	字符集編碼格式。
  interactiveMode	MCQA2.0功能開關(guān)，true表示開啟MCQA功能。
  quotaName	期望使用的交互式 Quota 組名字
  autoSelectLimit	數(shù)據(jù)量超過100萬限制時(shí)，需要配置此參數(shù)。

基于Java SDK啟用MCQA2.0功能

Java SDK詳情請參見Java SDK介紹。您需要通過Maven配置Pom依賴，配置示例如下。

<dependency>
    <groupId>com.aliyun.odps</groupId>
    <artifactId>odps-sdk-core</artifactId>
    <version>0.50.0-rc1</version>
</dependency>

創(chuàng)建Java程序，命令示例如下。

import ...;

public class SQLExecutorExample {

  public static void main(String args[]) {
    // 設(shè)置賬號(hào)和項(xiàng)目信息。
    // 阿里云賬號(hào)AccessKey擁有所有API的訪問權(quán)限，風(fēng)險(xiǎn)很高。強(qiáng)烈建議您創(chuàng)建并使用RAM用戶進(jìn)行API訪問或日常運(yùn)維，請登錄RAM控制臺(tái)創(chuàng)建RAM用戶
    // 此處以把AccessKey 和 AccessKeySecret 保存在環(huán)境變量為例說明。您也可以根據(jù)業(yè)務(wù)需要，保存到配置文件里
    // 強(qiáng)烈建議不要把 AccessKey 和 AccessKeySecret 保存到代碼里，會(huì)存在密鑰泄漏風(fēng)險(xiǎn)
    Account
        account =
        new AliyunAccount(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"),
                          System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
    Odps odps = new Odps(account);
    odps.setDefaultProject("<YOUR_PROJECT_NAME>");
    odps.setEndpoint("http://service.<regionid>.maxcompute.aliyun.com/api");

    // 準(zhǔn)備構(gòu)建SQLExecutor。
    SQLExecutorBuilder builder = SQLExecutorBuilder.builder();

    SQLExecutor sqlExecutor = null;
    try {
      // 創(chuàng)建一個(gè)默認(rèn)使用 MCQA2.0 模式的Executor。
      sqlExecutor = builder.odps(odps)
          .executeMode(ExecuteMode.INTERACTIVE)
          .quotaName("<YOUR_INTERACTIVE_QUOTA_NICKNAME>")
          .enableMcqaV2(true)
          .build();

      // 如果需要的話可以傳入查詢的特殊設(shè)置。
      Map<String, String> queryHint = new HashMap<>();
      queryHint.put("odps.sql.mapper.split.size", "128");
      // 提交一個(gè)查詢作業(yè)，支持傳入Hint。
      sqlExecutor.run("select count(1) from test_table;", queryHint);
      
      // 當(dāng)前查詢作業(yè)的logview。
      System.out.println("Logview:" + sqlExecutor.getLogView());
      // 當(dāng)前查詢作業(yè)的InstanceId
      System.out.println("InstanceId:" + sqlExecutor.getQueryId());
      
      ResultSet resultSet = sqlExecutor.getResultSet();
      while (resultSet.hasNext()) {
        System.out.println(resultSet.next());
      }
      // run another query
      sqlExecutor.run("select * from test_table;", new HashMap<>());

      // 獲取查詢結(jié)果的迭代器ResultSet，同步接口，可能會(huì)占用本線程直到查詢成功或失敗。
      // 獲取大量結(jié)果數(shù)據(jù)時(shí)推薦使用，分次讀取查詢結(jié)果。
      ResultSet resultSet = sqlExecutor.getResultSet();
      while (resultSet.hasNext()) {
        System.out.println(resultSet.next());
      }

    } catch (OdpsException | IOException e) {
      e.printStackTrace();
    } finally {
      if (sqlExecutor != null) {
        // 關(guān)閉Executor釋放相關(guān)資源。
        sqlExecutor.close();
      }
    }
  }
}