一、環(huán)境 軟件版本備注Ubuntu20.04.1 LTS操作系統(tǒng)kubernetesv1.18.161 * master node, 3 * worker nodeflink...
發(fā)簡(jiǎn)信
IP屬地：四川
-
flink on k8s native 測(cè)試小記-2021-05-12 -
Learn Flink —— Intro to the DataStream API 1.13本次練習(xí) 的重點(diǎn) 是充分全面介紹 DataStream API， 以使你能夠使用 其 編寫(xiě) 流式應(yīng)用程序。 什么能夠被轉(zhuǎn)化為流？ Flink 的 Java 和 Scala D...
-
Flink API簡(jiǎn)介
在實(shí)踐練習(xí)章節(jié)闡述了 Flink API 中 有狀態(tài)實(shí)時(shí)流處理的基本概念，并且舉例說(shuō)明了在應(yīng)用程序中如何應(yīng)用這些機(jī)制。 Data Pipelines & ETL章節(jié)介紹了有狀...
-
Flink學(xué)習(xí)：實(shí)踐練習(xí)練習(xí)的目標(biāo)和范圍 本次練習(xí)目前所包含的對(duì)于Apache Flink 的介紹內(nèi)容忽略了大量（ultimately important）細(xì)節(jié)，因此僅能夠滿足讓你可以開(kāi)始編寫(xiě)可伸縮...
-
Flink 操作場(chǎng)景Apache Flink 可以使用多用方式在不同的環(huán)境中部署，相對(duì)于部署環(huán)境的多樣性而言，F(xiàn)link集群的基本構(gòu)建方式仍是相同的，所應(yīng)用的操作原則也是相似的。 在本教程中，你...
-
PyFlink簡(jiǎn)介 —— Flink Python API
PyFlink 是Apache Flink 的Python API，它允許你構(gòu)建 可擴(kuò)展的批處理和流式處理的應(yīng)用程序，例如實(shí)時(shí)數(shù)據(jù)處理管道，大規(guī)模探索性數(shù)據(jù)分析、機(jī)器學(xué)習(xí)（M...
-
基于 Table API 實(shí)現(xiàn)實(shí)時(shí)報(bào)表
Apache Flink 提供了一個(gè)統(tǒng)一的關(guān)系A(chǔ)PI —— Table API, 用于批處理和實(shí)時(shí)計(jì)算。也就是說(shuō)，無(wú)論是在無(wú)界的實(shí)時(shí)數(shù)據(jù)流上還是在有界批量數(shù)據(jù)集上都可以使用相...
-
利用DataStream API 進(jìn)行欺詐檢測(cè)Apache Flink 提供了一個(gè) DataStream API，用于構(gòu)建健壯的、有狀態(tài)的流應(yīng)用程序。它提供了對(duì)狀態(tài)和時(shí)間的細(xì)粒度控制，允許實(shí)現(xiàn)高級(jí)的 事件驅(qū)動(dòng)（event...
-
Spark結(jié)構(gòu)化API數(shù)據(jù)源——文本文件
一、讀文本文件讀文本文件非常簡(jiǎn)單：只需要指定類型為textFile即可。如果使用textFile，分區(qū)目錄名將被忽略。如果要根據(jù)分區(qū)讀取和寫(xiě)入文本文件，你應(yīng)該使用text，它...