日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

新建Flink Vvp SQL類型的公共節點

Flink Vvp SQL節點是流式節點,運行于Flink云計算資源之上,支持對RDS MySQL、Table Store、Hive、Kafka、Hbase、Phoenix、AnalyticDB MySQL、AnalyticDB PostgreSQL和DataHub等類型的數據進行處理。本文介紹如何新建Flink Vvp SQL類型的公共節點。

背景信息

  • Flink Vvp SQL節點類型適用于阿里云Flink團隊提供的Flink集群模式(也稱為Flink全托管模式),提供對外API訪問。

  • Flink Vvp SQL公共節點是為了簡化計算模型、降低您使用Flink門檻而設計的可以使用標準SQL語義開發的公共節點。

操作步驟

方式一:寫SQL語句方式

  1. 登錄數據資源平臺控制臺

  2. 在頁面左上角,單擊菜單圖標,選擇協同

  3. 在頂部菜單欄,單擊選擇工作組圖標,選擇目標工作組,單擊資產加工

    說明

    若您已在資產加工頁面,請跳過“單擊資產加工”的操作。

  4. 在左側導航欄,單擊image圖標,選擇公共節點

  5. 單擊image圖標,在公共節點頁面,單擊新建節點

  6. 新建節點對話框,選擇Flink Vvp SQL節點類型,單擊確定

  7. 在節點編輯頁面,進行配置。

    1. 在頁面右側的節點屬性頁簽,自定義填寫節點名稱、節點標識以及描述等信息。

    2. 在編輯頁面,輸入SQL語句,單擊保存圖標。

    3. (可選)當需要在SQL中使用自定義函數時,單擊引用函數頁簽,在自定義函數列表找到需要的自定義函數,再返回編輯頁面輸入。若函數列表為空,則需要先新建函數,更多操作請參見新建自定義函數

    4. 確認節點信息對話框中,確認節點標識、節點名稱以及節點目錄信息設置無誤后,單擊確認

    5. 單擊頁面右側運行配置頁簽,選擇需要的開發計算引擎。

    6. (條件必選)如果代碼中存在輸入、輸出表或者節點變量,則需要手動添加節點的輸入、輸出和節點變量,或通過單擊編輯頁面的解析圖標,自動解析公共節點的輸入、輸出和節點變量。

      這里以解析為例介紹,詳細參數如下表所示。

      1. 單擊編輯頁面的解析圖標,在節點編輯頁面的運行配置頁簽,會顯示已自動解析出的輸入輸出和節點變量。

      2. 打開節點輸入后面的image.png開關,查看節點輸入。

      3. 打開節點輸出后面的image.png開關,查看節點輸出。

      4. 填寫節點變量值。

    7. 在節點編輯頁面,單擊左上角保存圖標。

方式二:上傳算法包方式

  1. 登錄數據資源平臺控制臺

  2. 在頁面左上角,單擊菜單圖標,選擇協同

  3. 在頂部菜單欄,單擊選擇工作組圖標,選擇目標工作組,單擊資產加工

    說明

    若您已在資產加工頁面,請跳過“單擊資產加工”的操作。

  4. 在左側導航欄,單擊image圖標,選擇公共節點

  5. 單擊image圖標,在公共節點頁面,單擊新建節點

  6. 新建節點對話框,選擇Flink Vvp SQL節點類型,單擊確定

  7. 在節點編輯頁面,進行配置。

    1. 在頁面右側的節點屬性頁簽,自定義填寫節點標識、節點名稱以及節點描述并上傳附件算法包。

      參數

      說明

      節點名稱

      節點的名稱。

      節點標識

      節點的唯一標識,由用戶自定義,同一個工作區內不可重復。

      節點目錄

      節點所屬目錄。

      公共節點版本

      首次創建時,默認為開發版本(Beta),待首次發布以后,再次發布,版本號依次疊加。

      節點描述

      節點的描述性信息,方便用戶理解和查找。

      節點附件

      上傳JAR包格式的節點資源文件。

    2. 在編輯頁面,輸入對應的腳本內容,單擊保存圖標。

    3. 確認節點信息對話框中,確認節點標識、節點名稱以及節點目錄信息設置無誤后,單擊確認

    4. 單擊頁面右側運行配置頁簽,選擇需要的開發計算引擎。

    5. (條件必選)如果代碼中存在輸入、輸出或者節點變量,則需要手動添加節點的輸入、輸出和節點變量,具體參數配置參見下表。

      1. 如果節點文件和腳本中有要求輸入,則打開節點輸入后面的image.png開關,單擊添加節點輸入,添加節點輸入,自定義填寫輸入標識并選擇輸入數據結構。

      2. 如果節點腳本中有要求輸出變量,則打開節點輸出后面的image.png開關,單擊添加節點輸出,添加節點輸出,自定義填寫輸出標識,并選擇輸出數據結構。

      3. 如果需要設置節點的全局控制參數,單擊添加參數,添加節點變量并賦值,關于全局變量的設置,更多信息,請參見新增工作組全局變量

        參數

        說明

        節點輸入

        輸入標識

        輸入變量的標識,系統默認配置,用戶可根據前面編寫的腳本內容來自定義,例如:Input

        數據結構

        輸入表的數據格式,由數據模型定義,在下拉列表中選擇輸入數據的邏輯表名稱,表示該計算資源中提供數據的數據表的結構。

        • 當選擇數據表時,需保證輸入的模型與上游節點的輸出數據模型相同。

        • 當選擇星號(*)時,代表數據結構為任意結構,用于對未創建數據模型的表進行操作。

        節點輸出

        輸出標識

        輸出變量的標識,用戶可根據前面編寫的腳本內容來自定義,例如:Output

        數據結構

        輸出表的數據格式,由數據模型定義,在下拉列表中選擇,表示該計算資源中輸出數據的數據表的結構。

        • 當選擇數據表時,需保證節點輸出的模型與下游節點的輸入數據模型相同。

        • 當選擇星號(*)時,代表數據結構為任意結構,用于對未創建數據模型的表進行操作。

        節點變量

        變量名

        算法的名稱,用戶自定義。

        變量值

        設置變量的值,值類型為字符串(String)類型。

        變量說明

        變量的說明信息。

    6. 設置Flink運行時參數。

    7. 完成上述參數配置后,單擊保存圖標,創建節點完成。