聊聊Flink：这次把Flink的触发器(Trigger)、移除器(Evictor)讲透
一、触发器(Trigger)Trigger 决定了一个窗口（由 window assigner 定义）何时可以被 window function 处理。每个 WindowAssigner 都有一个默认的 Trigger。如果默认 trigger 无法满足你的需要，你可以在 trigger(…)...
老周聊架构
0
聊聊Flink:这次把Flink的的window分类(滚动、滑动、会话、全局)...
一、窗口窗口（Window）是处理无界流的关键所在。窗口将流分成有限大小的“桶”，我们可以在其上应用算子计算。Flink可以使用window()和windowAll()定义一个窗口，二者都需要传入一个窗口分配器WindowAssigner，Window...
老周聊架构
0
聊聊Flink:Flink的分区机制
一、前言flink任务在执行过程中，一个流（stream）包含一个或多个分区（Stream partition）。TaskManager中的一个slot的subtask就是一个stream partition（流分区），一个Job的流（stream）分布在多个不同的Slot上执...
老周聊架构
0
聊聊Flink:Docker搭建Flink
一、准备工作 查看下Docker和Docker Compose版本，确保你安装了这些软件。 在 Flink 官网上下载 Flink 的 Docker 镜像。您可以使用以下命令从 Docker Hub 中下载： docker pull flink:1.18.0-scala_2.12 此命令将下...
老周聊架构
0
聊聊Flink:Flink的基础架构
一、前言 哈喽，大家好，我是微信公众号【老周聊架构】的作者老周，老周这次给大家分享下Flink系列的知识。作为Flink系列的开篇之作，我脑海中想着有没有一种很好的方式来让大家通俗易懂的了解Flink。因为你一上来就...
老周聊架构
0
手把手带你上手ChatGPT
一、ChatGPT介绍ChatGPT是一种基于深度学习的自然语言处理模型，它能够理解和生成人类语言，可以用于对话生成、文本摘要、自动化写作等多个领域。ChatGPT的全称是“Generative Pre-trained Transformer”，是由OpenAI...
老周聊架构
0
一文读懂 MySQL Explain 执行计划
一、前言上周老周的一个好朋友让我出一篇教你读懂 SQL 执行计划，和我另一位读者反馈的面试题如何排查慢 SQL 的强相关，索性先出一篇一文读懂 MySQL Explain 执行计划。Explain 执行计划你一定得会看，不然你简历上...
老周聊架构
0
聊聊 Pulsar: 在 Linux 环境上搭建 Pulsar
一、环境准备1.1 Java 环境为前提1.1.1 上传 jdk-8u261-linux-x64.rpm 到服务器并安装# 安装命令rpm -ivh jdk-8u261-linux-x64.rpm 1.1.2 配置环境变量# 编辑配置文件,jdk的bin目录到/etc/profile文件，对所有用户的...
老周聊架构
0
聊聊 Kafka: Consumer 源码解析之 ConsumerNetworkClient
一、Consumer 的使用Consumer 的源码解析主要来看 KafkaConsumer，KafkaConsumer 是 Consumer 接口的实现类。KafkaConsumer 提供了一套封装良好的 API，开发人员可以基于这套 API 轻松实现从 Kafka 服务端拉取消息的...
老周聊架构
0