小編給大家分享一下Apache Flink Table API和SQL API的外部數(shù)據(jù)源是什么，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

成都創(chuàng)新互聯(lián)公司是一家集網(wǎng)站建設(shè),青州企業(yè)網(wǎng)站建設(shè),青州品牌網(wǎng)站建設(shè),網(wǎng)站定制,青州網(wǎng)站建設(shè)報價,網(wǎng)絡(luò)營銷,網(wǎng)絡(luò)優(yōu)化,青州網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強(qiáng)企業(yè)競爭力?？沙浞譂M足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時我們時刻保持專業(yè)、時尚、前沿，時刻以成就客戶成長自我，堅持不斷學(xué)習(xí)、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實用型網(wǎng)站。

“Apache Flink的Table API與SQL API實現(xiàn)對接外部數(shù)據(jù)源的方式是Table connector直連外部數(shù)據(jù)源，Tabel connector將外部的數(shù)據(jù)源讀取到Flink中進(jìn)行計算或者把Apache Flink的結(jié)果寫入到外部數(shù)據(jù)源之中?！?/p>

Apache Flink的Table API與SQL API在之前已經(jīng)提到了Table Source與Table Sink的方式對實現(xiàn)數(shù)據(jù)源的注冊于結(jié)果的寫入等。Apache Flink已經(jīng)基本實現(xiàn)了對于的數(shù)據(jù)源的注冊于寫入的需求，但是仍然不夠靈活，用戶更加希望的可能是通過配置的方式實現(xiàn)對于不同數(shù)據(jù)源的選擇，并且實現(xiàn)數(shù)據(jù)的寫入。所以Apache Flink又提供了Table connector。

Table connector的實現(xiàn)不僅僅能夠更好的API與SQL Client，同時Table connector類似與實現(xiàn)了CREATE TABLE 的方式對數(shù)據(jù)進(jìn)行了注冊，能夠?qū)崿F(xiàn)再不修改代碼的情況下實現(xiàn)把數(shù)據(jù)寫入不同的位置。Tabel connector方法指定了需要連接Table connector對應(yīng)的Descriptor，withFormat方式指定了輸出或輸入的文件格式(csv,JSON,Parquet等)。withSchema方法指定了注冊在TableEnvironment中的表結(jié)構(gòu)。

tableEnv.connect(...)
.withFormat(...)
.withSchema(...)
.inAppendMode() //更新模式
.registerTableSource("MyTable")

通過以上方式注冊數(shù)據(jù)源后,我們可以直接把數(shù)據(jù)讀取或者寫入到該表中。也就是說我們可以實現(xiàn)類似于像操作DBMS表的數(shù)據(jù)一樣操作該表進(jìn)行數(shù)據(jù)讀取與寫入。

在當(dāng)前的很多云場景中，類似于阿里云，華為云等均提供了實時計算的產(chǎn)品，產(chǎn)品使用SQL的方式進(jìn)行注冊，注冊指定云廠商的其他產(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方法指定了連接對應(yīng)的Desciriptor，withFormat指定輸出或輸入的文件格式，例如JSON，CSV，Avro等。withSchema用以指定注冊在TableEnvironment中的表結(jié)構(gòu)。inAppendMode指定了數(shù)據(jù)的更新模式。最終通過registerTableSource方法將本次外部數(shù)據(jù)源注冊到TableEnvironment中，用以進(jìn)行查詢計算。

talbEnv.connect(...)
.withFormat(...)
.withSchema(...)
.inAppendMode()
.registerTableSource("TableName")

以上是“Apache Flink Table API和SQL API的外部數(shù)據(jù)源是什么”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學(xué)習(xí)更多知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！

本文名稱：ApacheFlinkTableAPI和SQLAPI的外部數(shù)據(jù)源是什么
本文地址：http://weahome.cn/article/cjggch.html