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