性能优化
-
Flink Job 执行流程
Flink On Yarn 模式 基于Yarn层面的架构类似 Spark on Yarn模式，都是由Client提交App到RM上面去运行，然后 RM分配第一个containe…
-
【C++】异常机制
异常 一、传统的处理错误的方式 二、C++异常概念 三、异常的使用 1. 异常的抛出和捕获 （1）异常的抛出和匹配原则 （2）在函数调用链中异常栈展开匹配原则 2. 异常的重新抛出…
-
Flink 数据类型 & TypeInformation信息
Flink流应用程序处理的是以数据对象表示的事件流。所以在Flink内部，我么需要能够处理这些对象。它们需要被序列化和反序列化，以便通过网络传送它们；或者从状态后端、检查点和保存点…
-
K 个一组翻转链表（链表反转，固定长度反转）（困难）
优质博文：IT-BLOG-CN 一、题目 给你链表的头节点head，每k个节点一组进行翻转，请你返回修改后的链表。 k是一个正整数，它的值小于或等于链表的长度。如果节点总数不是k的…
-
【C++】IO流
IO流 一、C语言的输入输出 二、流的概念 三、C++ IO流 1. C++标准IO流 2. C++文件IO流 四、stringstream 的简单介绍 1. 将数值类型数据格式化…
-
【C++】C++11中的常见语法(下)
C++11 一、可变参数模板 1. 递归函数方式展开参数包 2. 逗号表达式展开参数包 3. STL容器中的 empalce 相关接口函数 二、lambda 表达式 1. C++9…
-
Java 内存模型深度解析
优质博文：IT-BLOG-CN 一、并发编程模型的两个关键问题 【1】并发中常见的两个问题：线程之间如何通信及线程之间如何同步。通信是指线程之间以何种机制来交换信息。在命令式编程中…
-
@PostConstruct 注解分析
一、简介 如果需要在生成对象时就完成某些初始化操作，而且这些初始化操作又依赖于依赖注入@Autowired，那么就无法在构造函数中实现。为此，可以使用@PostConstruct注…
-
Flink Watermark和时间语义
Flink 中的时间语义 时间语义： EventTime：事件创建时间；Ingestion Time：数据进入Flink的时间；Processing Time：执行操作算子的本地系…
-
Flink Connector 开发
Flink Streaming Connector Flink是新一代流批统一的计算引擎，它需要从不同的第三方存储引擎中把数据读过来，进行处理，然后再写出到另外的存储引擎中。Con…
-
Flink 的时间属性及原理解析
Flink的API大体上可以划分为三个层次：处于最底层的ProcessFunction、中间一层的DataStream API和最上层的SQL/Table API，这三层中的每一层…
-
Java 19的未来：新特性、性能优化和更多
目录 前言 新特性的引入 1. 模式匹配的扩展 2. 增强的模式匹配异常处理 3. 基于记录的反射 4. 引入静态方法的接口 性能优化 1. 垃圾收集器的改进 2….
