Flink常用算子
OperatorsmapDataStream → DataStreamflatMapDataStream → DataStreamfliterDataStream → DataStreamkeyByDataStream → KeyedStream对数据进行分流reduceKeyedStream/Ke
Flink常见机制
反压机制Flink在1.5版本之前是基于TCP的流量控制和反压的。缺点：一个TaskManager执行的一个Task触发反压，该TaskManager和上游TaskManager的Socket就不能传输数据，从而影响到其他Task，也会影响到Barrier的流动，导致作业雪崩。在1.5版本之后，Fl
Flink中Barrier对齐机制
Barrier对齐机制以及Unaligned Checkpoints详解
Flink自定义实现端到端的exactly-once语义（java版本）
Flink 中有两个 Exactly-Once 语义实现，一个是 Kafka，另一个是 StreamingFileSink。参考他们实现的逻辑，来自定义实现MySQLSink的端到端exactly-once语义。分析：Flink的checkpoint机制（通过Chandy-Lamport）：JobM
Flink四大基石
CheckpointStateTimeWindow
[4] Flink大数据流式处理利剑: Flink集群安装和运行
本节笔者总结了如何在一个机器上安装集群，以及在多个机器上安装集群；并提到了通过zookeeper可以让Flink集群的Master节点也保持高可用；最后演示了如何部署一个SocketWindowWordCount.jar的例子，并在Flink的Web UI上面观察其job的执行情况和输出！
Flink消费kafka数据实时写入Clickhouse（java版本）
Flink消费kafka数据实时写入Clickhouse（java版本）
Java开发之实时计算--Flink
简介介绍计算框架对java开发的重要性介绍flink的架构介绍flink的基本概念：常用算子、checkpoint、state、window介绍flink的编程模型：DataStream、DataSet、Table API、SQL介绍flink的部署计算框架每个Java开发一定要懂至少一个流行的计算
Flink Table/SQL自定义Sources和Sinks全解析（附代码）
动态表是Flink Table和SQL API处理有界和无界数据的核心概念。在Flink中，动态表只是逻辑概念，其本身并不存储数据，而是将表的具体数据存储在外部系统（比如说数据库、键值对存储系统、消息队列）或者文件中。动态源和动态写可以从外部系统读写数据。在下面的描述中，动态源和动态写可以归结为co
Flink初体验(1)
软件安装版本号说明:JDK：1.8.0_302Flink：flink-1.14.2-bin-scala_2.11linux：CentOS 7.0一、安装 1.官网下载(https://flink.apache.org/downloads.html) Apache Flink 1.14.2 fo
Flink(scala)整合MySQL统计UV(unique visitor)
数据源是尚硅谷的课件, 需要的话可以私信我核心代码import org.apache.flink.api.common.serialization.SimpleStringSchemaimport org.apache.flink.configuration.Configurationimport
doris 15 详细docker 编译 以及drois-flink的编译
1. 编译对应的版本https://doris.apache.org/master/zh-CN/installing/compilation.html这里选择 docker15 编译2.docker 拉去镜像[root@basenode ~]# docker pull apache/incubat
Flink CDC 高频面试 13 问
大家好，我是土哥。Flink cdc 2.1.1 发布后，更新了很多新功能以及知识点，今天为大家全面总结了 CDC 的知识点如 无锁算法及面试高频考点。具体内容如下：1 cdc 简介2 Flink cdc 2.1.1 新增内容3 核心知识点解刨4 CDC 高频面试题1 cdc 简介CDC (Chan
Flink自定义Sink将数据存到MySQL
Flink自定义Sink将数据存到MySQL
Flink CDC 读取MySQL的数据
1、前提背景准备Flink在1.11之后就已经支持从MySQL增量读取Binlog日志的方式。pom文件如下：<properties> <scala.binary.version>2.11</scala.binary.version> <scal
【参赛作品95】DLI Flink SQL+kafka+（opengauss和mysql）进行电商实时业务数据分析
通过对opengauss和mysql的操作，可以很容易发现，mysql对数据类型兼容比较好。而且在创建表时，在数据库，表名和字段加上单引号或双引号都能成功建表，但是opengauss缺不行。Opengauss虽然有很多特性，但是在string的转换不是很好用，找了cast()函数还有其他方法都无法转
