网友收藏 2.4 Checkpoint技术前面已经讲到了,缓冲池的设计目的为了协调CPU速度与磁盘速度的鸿沟。因此页的操作首先都是在缓冲池中完成的。如果一条DML语句,如Update或Delete改变了页中的记录,那么此时页是脏的,即缓冲池中的页的版......
2023-10-12 12:09 阅读
阅读全文 网友收藏 文章浏览阅读2.8w次,点赞64次,收藏180次。前言:前面专门讲解了一篇关于tensorflow2.x的文件保存,主要是介绍了两种模式,一个是keras的h5文件,一个是tensorflow专用的SavedModel(.pb文件)文件,详细请参考:详解tensorflow2.0的模型......
2023-11-11 12:46 阅读
阅读全文 网友收藏 文章浏览阅读700次。Cache缓存import org.apache.spark.rdd.RDDimport org.apache.spark.{SparkConf, SparkContext}object CacheDemo { def main(args: Array[String]): Unit = { val conf:SparkConf=new SparkConf().setMaster("local[*]").setAppName("cacheDemo") val sc:Sp.._spa......
2024-01-23 04:57 阅读
阅读全文 网友收藏 文章浏览阅读1.5k次。redo日志本文为阅读《MySql是怎样运行的》的笔记,供大家参考。文章目录redo日志概述redo数据结构通用结构redo日志类型redo日志组Mini-Transactionredo日志写入内存redo log bufferredo log blockredo log 写入redo日志写入磁......
2023-11-11 13:57 阅读
阅读全文 网友收藏 asdsInnoDB 是事务安全的MySQL 存储引擎,设计上采用了类似于Oracle 数据库的架构。通常来说, InnoDB 存储引擎是OLTP应用中核心表的首选存储引擎。同时,也正是因为InnoDB 的存在,才使MySQL 数据库变得更有魅力。本章将详细介绍InnoD......
2023-10-12 12:09 阅读
阅读全文 网友收藏 文章浏览阅读2k次。状态管理状态后端1.状态的存储1.MemoryStateBackend2.FsStateBackend3.RocksDBBackend4.配置方式4.1 全局配置4.2 单任务配置2.状态的备份(checkpoint 和 savepoint)4.3 状态一致性4.3.1 flink状态的一致性级别4.3.2 端到端(end-to-end)......
2024-01-23 08:41 阅读
阅读全文 网友收藏 文章浏览阅读166次。(转自:http://space.itpub.net/12361284/viewspace-346)年初的时候拜读完了eygle写的《深入潜出》这本书,感觉收获很大。正好可以总结一下SCN和checkpoint这两个东东。Checkpoint很多人都把checkpoint的概念给复杂化了,其......
2024-01-23 04:25 阅读
阅读全文 网友收藏 文章浏览阅读1.1k次。文章目录TimeWindowTime WindowSession WindowCount WindowStatecheckPointTimeTime的概念: Event Time and Processing Time(事件时间和处理时间)处理时间:处理时间是指正在执行相应操作的机器的系统时间。当流程序按处理时间运......
2024-01-22 17:34 阅读
阅读全文 网友收藏 文章浏览阅读2.5k次。Flink Checkpoint(检查点)Flink中的每个函数和运算符都可以是有状态的(如果是Keyed Stream,使用ValueState、ListState等状态,如果是Operator State,实现CheckpointedFunction或CheckpointedList接口。使用ListState、MapState获取状......
2024-01-24 00:55 阅读
阅读全文