Flink中的时间 流处理与批处理流处理可以想象成有一条水流，只不过这条流里面流动的不是水而是数据。以京东统计销售额为例，想知道618当天的销售额是多少，有两种实现方法： 批处理：在618当天结束的时候，统一进行分析处理，大概就是一个select sum(amount) from trade。用水流的例子，可以把水流的水（数据）都集中在一个大水箱里面，然后在某一时刻分析水（数据）的情况，但是这样的分析并不是实时的，只 2022-06-02 Flink Flink
Flink 并行度、算子链及执行图 Flink 集群Flink 运行时由两种类型的进程组成：一个 JobManager 和一个或者多个 TaskManager。 Client 不是运行时和程序执行的一部分，而是用于准备数据流并将其发送给 JobManager。之后，客户端可以断开连接（detached mode），或保持连接来接收进程报告（attached mode）。客户端可以作为触发执行 Java/Scala 程序的一部分运行 2022-05-17 Flink Flink
MySQL BinLog 更新 参考资料：5.4.4 The Binary Log MySQL版本：MySQL 8.0 结论： 只有事务提交才会更新binlog 一个事务小于binlog cache size的时候会使用内存缓存，大于binlog cache size但是小于max binlog cache size会同时使用内存和临时文件（磁盘）作缓存，大于max binlog cache size会直接报错 Bina 2022-03-15 Database Databse
《Rust语言圣经》笔记（基础入门） 《Rust语言圣经》笔记（基础入门）最近在学习《Rust语言圣经》 ，并参与了贡献，希望大家多提意见，一起完善这个项目。 usize、isize类型的引入isize 和 usize 类型取决于程序运行的计算机cpu类型：若cpu是32位的，则这两个类型是32位的，同理，若cpu是64位，那么它们则是64位。 所有权的引入Rust之所以能万众瞩目，是因为其内存安全的特性。在以往，内存安全几乎都是通过 2022-01-24 Rust Rust
Asynchronous Programming in Rust Asynchronous Programming in Rust 记录对Rust异步编程的一些理解 关于Tokio Runtime Tokio is able to concurrently run many tasks on a few threads by repeatedly swapping the currently running task on each thread. Howeve 2022-01-05 Rust Rust Tokio
Bitcask BitcaskA Log-Structured Fast KV Store学习Bitcask的缘由是在Rust中文社区看到了一名高中生正在用Rust实现一个Key-Value数据库系统：Dorea，抱着学习的心态下载了这个项目研究了一下，这个数据库系统使用的存储方案是一个基于hash表结构和key-value的日志型存储模型，名为Bitcask。 Bitcask起源于一篇同名的数据库模型论文，这篇 2021-12-30 Database Database Bitcask