Flink SQL 1.11 on Zeppelin 平台化實踐
簡介： 鑒於有很多企業都無法配備專門的團隊來解決 Flink SQL 平台化的問題，那么到底有沒有一個開源的、開箱即用的、功能相對完善的組件呢？答案就是本文的主角——Apache Zeppelin。 作者：LittleMagic 大數據領域 SQL 化開發的風潮方興未艾（所謂 ...
原文：Flink SQL 1.11 on Zeppelin 平台化實踐
作者：LittleMagic 大數據領域 SQL 化開發的風潮方興未艾 所謂 Everybody knows SQL ，Flink 自然也不能 免俗 。 Flink SQL 是 Flink 系統內部最高級別的 API，也是流批一體思想的集大成者。 用戶可以通過簡單明了的 SQL 語句像查表一樣執行流任務或批任務，屏蔽了底層 DataStream DataSet API 的復雜細節，降低了使用門檻。 ...
2020-11-27 15:57 0 416 推薦指數：
相關推薦
Flink SQL 1.11新功能詳解：Hive 數倉實時化 & Flink SQL + CDC 實踐
問題導讀1.Flink 1.11 有哪些新功能？ 2.如何使用 flink-cdc-connectors 捕獲 MySQL 和 Postgres 的數據變更? 3.怎樣利用 Flink SQL 做多流 join 后實時同步到 Elasticsearch 中 ...
Flink 1.11 Table & SQL深度解讀
1. kafka table DDL 動態table,后者定義覆蓋前者, 一次創建多次使用 2.clone table 完整繼承、或者覆蓋OPTION 3.性 ...
唯品會：在 Flink 容器化與平台化上的建設實踐
簡介： 唯品會 Flink 的容器化實踐應用，Flink SQL 平台化建設，以及在實時數倉和實驗平台上的應用案例。 轉自dbaplus社群公眾號作者：王康，唯品會數據平台高級開發工程師 自 2017 年起，為保障內部業務在平時和大促期間的平穩運行，唯品會就開始基 ...
Flink1.11中的CDC Connectors操作實踐
Flink1.11引入了CDC的connector，通過這種方式可以很方便地捕獲變化的數據，大大簡化了數據處理的流程。Flink1.11的CDC connector主要包括：MySQL CDC和Postgres CDC,同時對Kafka的Connector支持canal-json ...
Flink1.11中的CDC Connectors操作實踐
Flink1.11引入了CDC的connector，通過這種方式可以很方便地捕獲變化的數據，大大簡化了數據處理的流程。Flink1.11的CDC connector主要包括：MySQL CDC和Postgres CDC,同時對Kafka的Connector支持 ...