包含标签:flink 的文章
-
【Flink入门修炼】1-3 Flink WordCount 入门实现
本篇文章将带大家运行 Flink 最简单的程序 WordCount。先实践后理论,对其基本输入输出、编程代码有初步了解,后续篇章再对 Flink 的各种概念和架构进行介绍…… -
Apache Doris 整合 FLINK CDC + Iceberg 构建实时湖仓一体的联邦查询
1概况 本文展示如何使用 Flink CDC + Iceberg + Doris 构建实时湖仓一体的联邦查询分析,Doris 1.1版本提供了Iceberg的支持,本文主要展示Doris和Iceberg怎…… -
Flink Format系列(2)-CSV
Flink的csv格式支持读和写csv格式的数据,只需要指定 'format' = 'csv',下面以kafka为例。 CREATE TABLE user_behavior ( user_id BIGINT, item_id BIGI…… -
FlinkSql 窗口函数
Windowing TVF 以前用的是Grouped Window Functions(分组窗口函数),但是分组窗口函数只支持窗口聚合 现在FlinkSql统一都是用的是Windowing TVFs(窗口表值…… -
【大数据面试题】002 Flink 如何实现 Exactly-Once 语义
一步一个脚印,一天一道大数据面试题。 在流式大数据处理框架中,Exactly-Once 语义对于确保每条数据精确地只被消费一次(避免重复读取和丢失读取)非常重要…… -
Flink Checkpoint过程
Checkpoint 使用了 Chandy-Lamport 算法 流程 1. 正常流式处理(尚未Checkpoint) 如下图,Topic 有两个分区,并行度也为 2,根据奇偶数 我们假设任务从 Kaf…… -
spark-flink设计思想之吸星大法-1
Spark和Flink都是大数据处理框架,它们的设计思想有一些不同之处。以下是对它们设计思想的简要对比: 数据模型和计算模型: Spark:Spark使用弹性分布式…… -
Flink多流转换(1)—— 分流&合流
目录 分流 代码示例 使用侧输出流 合流 联合(Union) 连接(Connect) 简单划分的话,多流转换可以分为“分流”和“合流”两大类 目前分流的操作一般是通过侧输…… -
【极数系列】Flink详细入门教程 & 知识体系 & 学习路线(01)
文章目录 01 引言 02 Flink是什么 2.1 Flink简介 2.2 Flink架构 2.3 Flink应用场景 2.4 Flink运维 03 Flink环境搭建 3.1 Flink服务端环境搭建 3.2 Fl…… -
【极数系列】Flink配置参数如何获取?(06)
文章目录 gitee码云地址 简介概述 01 配置值来自.properties文件 1.通过路径读取 2.通过文件流读取 3.通过IO流读取 02 配置值来自命令行 03 配置来自系……