flink基础知识点-腾讯云开发者社区

开发者社区

文档建议反馈控制台

腾讯云架构师技术同盟

文章/答案/技术大牛

发布

flink基础知识点

针对小白初学flink进行的社区博客

专栏成员

10

文章

1761

阅读量

14

订阅数

flink之时间和窗口

所谓的“窗口”，一般就是划定的一段时间范围，也就是“时间窗”；对在这范围内的数据进行处理，就是所谓的窗口计算。所以窗口和时间往往是分不开的。

2024-06-17

1590

flink之Datastram3

Flink的DataStream API专门提供了向外部写入数据的方法：addSink。与addSource类似，addSink方法对应着一个“Sink”算子，主要就是用来实现与外部系统连接、并将数据提交写入的；Flink程序中所有对外的输出操作，一般都是利用Sink算子完成的。

2024-06-16

800

flink之DataStream2

这是接上文的flink之Datastream1，文章链接 https://cloud.tencent.com/developer/article/2428018?shareByChannel=link

2024-06-15

840

flink之DataStream算子1

Flink对POJO（Plain Ordinary Java Object简单的Java对象，实际就是普通JavaBeans）类型的要求如下：

2024-06-14

1210

flink之taskslots和并行度的关系

这是在算子链的博客基础上写的，想要看到一些作业流程，可以去flink之算子链的那篇博客理清作业的并行度的关系。

2024-06-13

3450

flink之算子链

一个数据流在算子之间传输数据的形式可以是一对一（one-to-one）的直通（forwarding）模式，也可以是打乱的重分区（redistributing）模式，具体是哪一种形式，取决于算子的种类。

2024-06-13

3570

flink之核心概念、基础配置

当处理数据的数据量过大的时候，flink会把一个算子操作复制多份到多个节点，数据来了之后就可以到其中任意一个执行。这样一来，一个算子任务就被拆分成了多个并行的“子任务”（subtasks），再将它们分发到不同节点，就真正实现了并行计算。

2024-06-12

1320

flink之运行架构、作业提交流程

JobManager 是一个 Flink 集群中任务管理和调度的核心，是控制应用执行的主进程。

2024-06-12

1850

flink集群模式

TaskManager的组成：由若干个（在底层flink-conf.yaml文件配置）taskSlot组成

2024-06-11

1950

flink基础之wordcount计算

在学习大数据，最基础的入门程序就是计算wordcount，即统计每个单词出现的次数

2024-06-11

1030

没有更多了

社区活动

Python精品学习库

代码在线跑，知识轻松学

博客搬家 | 分享价值百万资源包

自行/邀约他人一键搬运博客，速成社区影响力并领取好礼

技术创作特训营·精选知识专栏

往期视频·干货材料·成员作品最新动态