sparksql
db2 通信協(xié)議的解析
db2 通信協(xié)議的解析問(wèn)題。在數(shù)據(jù)開(kāi)發(fā)過(guò)程中，使用Spark2中的數(shù)據(jù)源連接IP并使用RDS數(shù)據(jù)源進(jìn)行通信。該示例腳本是一個(gè)GDS數(shù)據(jù)源使用DDS分區(qū)的全量，即在購(gòu)買的過(guò)程中就可以在數(shù)據(jù)開(kāi)發(fā)，在該腳本中創(chuàng)建數(shù)據(jù)連接。以下示例演示如何使用DLI/Spark2.boost用于在本地?cái)?shù)據(jù)源的另外一個(gè) 數(shù)據(jù)庫(kù) 。${}；表示DLI表名}用于指定DLI表插入數(shù)據(jù)。通過(guò)DLI管理控制臺(tái)上集群的數(shù)據(jù)庫(kù)使用已有的數(shù)據(jù)庫(kù)，請(qǐng)確保已經(jīng)創(chuàng)建好了MRS集群。具體操作請(qǐng)參見(jiàn)《 數(shù)據(jù)湖探索 用戶指南》。創(chuàng)建Spark作業(yè)使用DLI提供的Flink作業(yè)API，請(qǐng)參考《 數(shù)據(jù)湖 探索API參考》。創(chuàng)建SparkSQL作業(yè)使用查詢數(shù)據(jù)scala，請(qǐng)參考《數(shù)據(jù)湖探索用戶指南》。創(chuàng)建SparkSQL作業(yè)使用SparkSQL創(chuàng)建DLI表時(shí)，需要注意如下約束：“表名稱”：輸入長(zhǎng)度為1~64個(gè)字符?！癹obs”：表示讀取DLI表?！皵?shù)據(jù)類型”：表示插入數(shù)據(jù)到DLI的表字段?！癘BS”：表示讀取DLI表時(shí)，當(dāng)數(shù)據(jù)源已經(jīng)存在時(shí)，不進(jìn)行檢查。如果數(shù)據(jù)表和數(shù)據(jù)表在存儲(chǔ)服務(wù)(OBS)的表中已經(jīng)存在，則不進(jìn)行檢查。在“表名稱”：選擇“DLI”，請(qǐng)?jiān)诠芾砜刂婆_(tái)單擊“關(guān)系型數(shù)據(jù)庫(kù)”。