Demo：基於 Flink SQL 構建流式應用
Flink 1.10.0 於近期剛發布，釋放了許多令人激動的新特性。尤其是 Flink SQL 模塊，發展速度非常快，因此本文特意從實踐的角度出發，帶領大家一起探索使用 Flink SQL 如何快速構建流式應用。 本文將基於 Kafka, MySQL, Elasticsearch, Kibana ...
原文：Flink1.11 SQL Demo: 構建一個端到端的流式應用
本文將基於 Kafka, MySQL, Elasticsearch, Kibana，使用 Flink SQL 構建一個電商用戶行為的實時分析應用。本文所有的實戰演練都將在 Flink SQL CLI 上執行，全程只涉及 SQL 純文本，無需一行 Java Scala 代碼，無需安裝 IDE。本實戰演練的最終效果圖： 准備 一台裝有 Docker 的 Linux 或 MacOS 計算機。 使用 Do ...
2020-07-23 11:50 11 1578 推薦指數：
相關推薦
使用flink Table &Sql api來構建批量和流式應用(3)Flink Sql 使用
從flink的官方文檔，我們知道flink的編程模型分為四層，sql層是最高層的api，Table api是中間層，DataStream/DataSet Api 是核心，stateful Streaming process層是底層實現。 其中， flink dataset ...
Flink1.11中的CDC Connectors操作實踐
Flink1.11引入了CDC的connector，通過這種方式可以很方便地捕獲變化的數據，大大簡化了數據處理的流程。Flink1.11的CDC connector主要包括：MySQL CDC和Postgres CDC,同時對Kafka的Connector支持canal-json ...
Flink1.11 解決 No ExecutorFactory found to execute the application
在使用Flink1.11的時候寫了個本地Test 運行的時候發現報錯了，具體如下 查看Flink1.11 release文檔發現 從Flink 1.11.0 開始flink-streaming-java不再依賴flink-client需要單獨引用，那么增加相應依賴 ...
使用flink Table &Sql api來構建批量和流式應用(1)Table的基本概念
從flink的官方文檔，我們知道flink的編程模型分為四層，sql層是最高層的api，Table api是中間層，DataStream/DataSet Api 是核心，stateful Streaming process層是底層實現。 其中， flink ...
使用flink Table &Sql api來構建批量和流式應用(2)Table API概述
從flink的官方文檔，我們知道flink的編程模型分為四層，sql層是最高層的api，Table api是中間層，DataStream/DataSet Api 是核心，stateful Streaming process層是底層實現。 其中， flink dataset ...