写这篇文章，记录我2019年时做Flink的编程练习，记录一些关键思想套路，为以后举一反三，触类旁通之用。以下需求都非常基础和简单，关键在思路，不在意代码细节。 项目场景 普通的互联网电商平...

1、Flink是如何支持批流一体的？ 2、Flink是如何做到高效的数据交换的？ 3、Flink是如何做容错的？ 4、Flink 分布式快照的原理是什么？ 5、Flink 是如何保证Exactly-once语义的？ 6、Flink 的 k...

本文作者为京东算法服务部的张颖和段学浩，并由 Apache Hive PMC，阿里巴巴技术专家李锐帮忙校对。主要内容为： 1.背景 2.Flink SQL 的优化3.总结一、背景 目前，京东搜索推荐的数据处理流程如...

1、概述 1.1、基础介绍 Apache Flink is a framework and distributed processing engine for stateful computations over unbounded and bounded data streams. 1.2、数据处理结构演变 1）传统...

原标题：FlinkSQL 数据权限之数据脱敏解决方案 作者 | HamaWhite 审校| 蔡芳芳 在当今数字化时代，数据已经成为企业和组织中不可或缺的重要资产，包括个人信息、商业机密、财务数据等等。然而，...

Flink的Transformation转换主要包括四种：单数据流基本转换、基于Key的分组转换、多数据流转换和数据重分布转换。读者可以使用Flink Scala Shell或者Intellij Idea来进行练习：Flink Scala Shel...