前面我们了解过了当Redis执行一个命令时，服务端做了哪些事情，不了解的同学可以看一下这篇文章走近源码：Redis如何执行命令。今天就一起来看看Redis的命令执行过程中客户端都做了什么事情。启动客户端首先看redis-cli.c文件的main函数，也就是我们输入redis-cli命令时所要执行的函数。main函数主要是给config变量的各个属性设置默认值。比如：hostip：要连接的服...

Hadoop压缩

第一个Hadoop程序

MapReduce的类型

把Claude Code从“聊天框”改造成“能自查的执行体”，关键在于三层验证闭环：搭建MCP环境让它触达真实系统、跑代码看输出；接入自动化测试套件，用客观结果替代“我觉得没问题”；沉淀基于反馈的代码审查技能，定期更新固化你的标准。高手与普通用户的差距不在提示词，而在能否让它自己跑、自己查、自己证伪。

把Claude Code从“聊天框”改造成“能自查的执行体”，关键在于三层验证闭环：搭建MCP环境让它触达真实系统、跑代码看输出；接入自动化测试套件，用客观结果替代“我觉得没问题”；沉淀基于反馈的代码审查技能，定期更新固化你的标准。高手与普通用户的差距不在提示词，而在能否让它自己跑、自己查、自己证伪。

把Claude Code从“聊天框”改造成“能自查的执行体”，关键在于三层验证闭环：搭建MCP环境让它触达真实系统、跑代码看输出；接入自动化测试套件，用客观结果替代“我觉得没问题”；沉淀基于反馈的代码审查技能，定期更新固化你的标准。高手与普通用户的差距不在提示词，而在能否让它自己跑、自己查、自己证伪。

本文摘要： 本文重点介绍了Flink流处理中的两个核心概念：时间属性和Watermark机制。首先阐述了Flink支持的三种时间属性：事件时间(EventTime)、处理时间(ProcessTime)和摄入时间(IngestionTime)，并通过图示说明了它们的区别。然后详细讲解了Watermark的工作原理，包括其定义、作用以及处理迟到数据的三种方法。

前面我们了解到在方法中会创建四个 Future，用来支持不同类型的状态写入。if (null!} else {我们主要关心 ManagedState，ManagedState 都是调用方法来写入数据的，下面具体看 KeyedState 和 OperatorState 的具体实现。本文我们重点梳理了 KeyedState 数据写入的代码。其主要步骤包括：同步拷贝状态数据的引用，创建 Checkpoi

本文分析了Flink中Watermark的源码实现，主要包含三个部分：1) Watermark的定义，它是一个带有时间戳的StreamElement；2) Watermark的生成过程，通过assignTimestampsAndWatermarks方法初始化，创建TimestampsAndWatermarksOperator并设置定时器周期性发送；3) 下游处理机制，获取上游最小Watermark