通過以上方式注冊數據源后,我們可以直接把數據讀取或者寫入到該表中。也就是說我們可以實現類似于像操作DBMS表的數據一樣操作該表進行數據讀取與寫入。
在當前的很多云場景中，類似于阿里云，華為云等均提供了實時計算的產品，產品使用SQL的方式進行注冊，注冊指定云廠商的其他產品與存儲格式等 withSchema ，指定讀取的數據結構 withSchema 與更新的模式等即可實現數據的讀取或計算結果的寫入。
CREATE TABLE datahub_stream(
name VARCHAR,
age BIGINT,
birthday BIGINT
) WITH (
type=\’產品\’,
endPoint=\’…\’,
project=\’…\’,
topic=\’…\’
…
);
我們在使用時涉及的步驟也大致分為這些，如下代碼。connect方法指定了連接對應的Desciriptor，withFormat指定輸出或輸入的文件格式，例如JSON，CSV，Avro等。withSchema用以指定注冊在TableEnvironment中的表結構。inAppendMode指定了數據的更新模式。最終通過registerTableSource方法將本次外部數據源注冊到TableEnvironment中，用以進行查詢計算。
talbEnv.connect(…)
.withFormat(…)
.withSchema(…)
.inAppendMode()
.registerTableSource(\”TableName\”)
以上是“Apache Flink Table API和SQL API的外部數據源是什么”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注資訊頻道！
更多關于云服務器，域名注冊，虛擬主機的問題，請訪問三五互聯官網：m.shinetop.cn