基於Flink的視頻直播案例（上）
目錄 數據產生 Logstash部分 Kafka部分 Flink部分 配置/准備代碼 視頻核心指標監控 本案例參考自阿里雲的視頻直播解決方案之視頻核心指標監控和視頻直播解決方案之直播數字化運營。 基於Kafka ...
原文：Flink 案例分析
Flink程序的執行過程 no desc 說明 詳情 env 獲取flink的執行環境 批處理：ExecutionEnvironment env ExecutionEnvironment.getExecutionEnvironment 流處理：StreamExecutionEnvironment env StreamExecutionEnvironment.getExecutionEnvironm ...
2020-09-23 12:48 0 1173 推薦指數：
相關推薦
Flink 案例整合
1.概述 Flink 1.1.0 版本已經在官方發布了，官方博客於 2016-08-08 更新了 Flink 1.1.0 的變動。在這 Flink 版本的發布，添加了 SQL 語法這一特性。這對於業務場景復雜，依賴於 SQL 來分析統計數據，算得上是一個不錯的福利。加上之前有同學和朋友郵件 ...
Flink學習（八） Flink SQL & Table 編程和案例
Flink Table & SQL 概述背景我們在前面的課時中講過 Flink 的分層模型，Flink 自身提供了不同級別的抽象來支持我們開發流式或者批量處理程序，下圖描述了 Flink 支持的 4 種不同級別的抽象。 Table API 和 SQL 處於最頂端，是 Flink ...
flink內存模型詳解與案例
任務提交時的一些yarn設置（通用客戶端模式） 指定並行度 -p 5 \ 指定yarn隊列 -Dyarn.a ...
Flink流處理之迭代案例
當前Flink將迭代的重心集中在批處理上，之前我們談及了批量迭代和增量迭代主要是針對批處理（DataSet）API而言的，而且Flink為批處理中的迭代提供了針對性的優化。 可是對於流處理（DataStream），Flink相同提供了對迭代的支持。這一節我們主要來分析流處理中的迭代 ...
Flink| 實時需要分析
用戶行為分析 統計分析 點擊、瀏覽； 熱門商品、近期熱門商品、分類熱門商品，流量統計； 偏好統計 收藏、喜歡、評分、打標簽； 用戶畫像、推薦列表（結合特征工程和機器學習算法） 風險控制 下訂單、支付、登錄 刷單監控，訂單實效監控 ...
flink checkpoint 源碼分析 （一）
轉發請注明原創地址http://www.cnblogs.com/dongxiao-yang/p/8029356.html checkpoint是Flink Fault Tolerance機制的重要構成部分，flink checkpoint的核心類名為 ...
Flink特點分析
是Stratosphere系統的核心開發人員，2014年12月，Flink一躍成為Apache軟件基金會的頂級項目。 ...