溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

apache flink指的是什么

發(fā)布時(shí)間:2020-10-30 12:38:55 來(lái)源:億速云 閱讀:127 作者:小新 欄目:建站服務(wù)器

小編給大家分享一下apache flink指的是什么,希望大家閱讀完這篇文章后大所收獲,下面讓我們一起去探討吧!

Apache Flink是由Apache軟件基金會(huì)開(kāi)發(fā)的開(kāi)源流處理框架,其核心是用Java和Scala編寫的分布式流數(shù)據(jù)流引擎。Flink以數(shù)據(jù)并行和流水線方式執(zhí)行任意流數(shù)據(jù)程序,F(xiàn)link的流水線運(yùn)行時(shí)系統(tǒng)可以執(zhí)行批處理和流處理程序。此外,F(xiàn)link的運(yùn)行時(shí)本身也支持迭代算法的執(zhí)行。

Flink提供高吞吐量、低延遲的流數(shù)據(jù)引擎以及對(duì)事件-時(shí)間處理和狀態(tài)管理的支持。Flink應(yīng)用程序在發(fā)生機(jī)器故障時(shí)具有容錯(cuò)能力,并且支持exactly-once語(yǔ)義。程序可以用Java、Scala[9]、Python[和SQL等語(yǔ)言編寫,并自動(dòng)編譯和優(yōu)化到在集群或云環(huán)境中運(yùn)行的數(shù)據(jù)流程序。

Flink并不提供自己的數(shù)據(jù)存儲(chǔ)系統(tǒng),但為Amazon Kinesis、Apache Kafka、HDFS、Apache Cassandra和ElasticSearch等系統(tǒng)提供了數(shù)據(jù)源和接收器。

Apache Flink的數(shù)據(jù)流編程模型在有限和無(wú)限數(shù)據(jù)集上提供單次事件(event-at-a-time)處理。在基礎(chǔ)層面,F(xiàn)link程序由流和轉(zhuǎn)換組成。 “從概念上講,流是一種(可能永無(wú)止境的)數(shù)據(jù)流記錄,轉(zhuǎn)換是一種將一個(gè)或多個(gè)流作為輸入并因此產(chǎn)生一個(gè)或多個(gè)輸出流的操作”。

Apache Flink包括兩個(gè)核心API:用于有界或無(wú)界數(shù)據(jù)流的數(shù)據(jù)流API和用于有界數(shù)據(jù)集的數(shù)據(jù)集API。Flink還提供了一個(gè)表API,它是一種類似SQL的表達(dá)式語(yǔ)言,用于關(guān)系流和批處理,可以很容易地嵌入到Flink的數(shù)據(jù)流和數(shù)據(jù)集API中。Flink支持的最高級(jí)語(yǔ)言是SQL,它在語(yǔ)義上類似于表API,并將程序表示為SQL查詢表達(dá)式。

看完了這篇文章,相信你對(duì)apache flink指的是什么有了一定的了解,想了解更多相關(guān)知識(shí),歡迎關(guān)注億速云行業(yè)資訊頻道,感謝各位的閱讀!

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI