源码 过程flink rpc
Flink SQL建表语句示例
Hive CREATE EXTERNAL TABLE jc.judgmentDocumentods( odsId STRING, caseTitle STRING, plaintiff STRING, caseTypeShow INT, releaseDate STRING, caseSource ......
Flink Sql On Hive
TableEnvironment // ********************** // FLINK STREAMING QUERY // ********************** import org.apache.flink.streaming.api.environment.Stream ......
zookeeper源码(05)数据存储
本文详细分析一下zookeeper的数据存储。 ZKDatabase 维护zookeeper服务器内存数据库，包括session、dataTree和committedlog数据，从磁盘读取日志和快照后启动。 关键字段 // 数据节点树 protected DataTree dataTree; pro ......
03_内核源码组织架构
一、Linux内核特征 Linux内核组织形式为整体式结构 进程调度方式简单而有效 支持内核线程（或称为守护进程） 支持多种平台的虚拟内存管理 虚拟文件系统 模块机制 增加系统调用 面向对象 二、Linux内核五大子系统 三、系统数据结构 在Linux内核中使用频率较高的数据结构： task_str ......
01_编译Linux源码
编译Linux源码 进入源码目录 /usr/src 从当前机器的启动目录拷贝配置信息到源代码目录。这步操作的意思是我们编译内核的配置采用用当前环境一致的配置 cp -v /boot/config-$(uname -r) .config 可以通过如下命令启动配置界面 make menuconfig s ......
从源码分析 MySQL 身份验证插件的实现细节
最近在分析ERROR 1045 (28000): Access denied for user 'root'@'localhost' (using password: YES)这个报错的常见原因。 在分析的过程中，不可避免会涉及到 MySQL 身份验证的一些实现细节。 加之之前对这一块就有很多疑问， ......
SpringMVC中如何设置响应的Content-Type(源码分析)
转载自：https://blog.csdn.net/CaptHua/article/details/122004067 问题 写这篇文章源于笔者在一次调试接口的时候遇到的一个问题: 在浏览器中调用接口,页面显示的内容中有乱码, 但是查看响应中的内容是没有乱码的, 而且在Postman中调用返回的结果 ......
Flink写文件
简介 StreamingFileSink 提供了将数据分桶写入文件系统的功能。 如何分桶是可以配置，默认使用基于时间的分桶策略，每个小时创建一个新的桶，也可以自定义分桶策略。 文件滚动策略支持两种方式，基于时间和文件大小的DefaultRollingPolicy策略和基于Flink检查点的OnChe ......
安装HUE并配置连接Hive&Flink&TIDB
创建用户 groupadd hadoop useradd -g hadoop hadoop 解压编译 wget https://cdn.gethue.com/downloads/hue-4.8.0.tgz PREFIX=/usr/share make install 集成Hive Conf 在/op ......
HUE中执行Flink SQL
要解决的问题 解决HUE操作大数据量Hive表时，执行报错的问题。 为开发人员或数据管理人员提供一个便捷的Flink SQL交互式查询工具，简化SQL验证的流程，进而提高工作效率。 功能介绍 Flink SQL 读写Kafka Flink SQL 读写HDFS Flink SQL 关联 Flink ......
一般情况下的阿波罗尼斯圆的方程的推导过程
首先介绍一下什么是阿波罗尼斯圆: 已知平面上两点 \(A, B\), 则所有满足 \(\frac{PA}{PB}=k\) 且不等于 \(1\) 的点 \(P\) 的轨迹是一个以定比 \(m:n\) 内分和外分定线段 \(AB\) 的两个分点的连线为直径的圆. 这个轨迹最先由古希腊数学家阿波罗尼斯发现 ......
BSP视频教程第29期：J1939协议栈CAN总线专题，源码框架，执行流程和应用实战解析，面向车通讯，充电桩，模组通信等(2024-01-08)
视频教程汇总帖：https://www.armbbs.cn/forum.php?mod=viewthread&tid=110519 继前面CANopen专题视频教程后，再推出CAN总线的又一个重要协议栈J1939专题视频 J1939在车通讯上应用比较多，现在电动车充电桩还有各种模组的通信也非常多基于 ......
聊聊ChatGLM-6B的源码分析
基于ChatGLM-6B第一版，要注意还有ChatGLM2-6B以及ChatGLM3-6B 转载请备注出处：https://www.cnblogs.com/zhiyong-ITNote/ PrefixEncoder 作用：在微调时（以P-Tuning V2为例），方法训练时冻结模型的全部参数，只激活 ......
SQL语句在MySQL中的执行过程
SQL语句在MySQL中的执行过程 MySQL 主要分为 Server 层和引擎层，Server 层主要包括连接器、查询缓存、分析器、优化器、执行器，同时还有一个日志模块（binlog），这个日志模块所有执行引擎都可以共用，redolog 只有 InnoDB 有。 引擎层是插件式的，目前主要包括，M ......
ArrayList源码阅读
目录简介例子继承结构概览代码分析成员变量方法迭代器子列表总结参考链接 本人的源码阅读主要聚焦于类的使用场景，一般只在java层面进行分析，没有深入到一些native方法的实现。并且由于知识储备不完整，很可能出现疏漏甚至是谬误，欢迎指出共同学习 本文基于corretto-17.0.9源码，参考本文时请 ......
公开号CN117354339A —— 数据传输专利 —— 解决了相关技术在进行数据传输的过程中时效性较差的技术问题
看到一个新闻： 地址： https://mbd.baidu.com/newspage/data/landingsuper?context=%7B%22nid%22%3A%22news_9290711970017276653%22%7D&n_type=-1&p_from=-1 ......
如何优雅地输出统计过程的运行结果
打印（Print）是一件非常消耗资源的事情，尤其是在编写宏程序时，最好将过程步的输出结果保存在数据集中，而不是默认输出到结果查看器中。如果宏程序内部调用的过程步特别多，会导致程序运行效率变慢，也会把结果查看器的内容弄得一团糟。 下面介绍几种方法，将过程步的运行结果直接保存到数据集中，避免“打印”操作 ......
TCP三次握手源码分析
一、环境说明 内核版本：Linux 3.10 内核源码地址：https://elixir.bootlin.com/linux/v3.10/source (包含各个版本内核源码，且网页可全局搜索函数) 二、TCP协议格式 各字段的作用： 源端口号：用于指定本地程序绑定的端口; 目的端口号：用于指定远端 ......
kafka源码阅读之MacBook Pro M1搭建Kafka2.7版本源码运行环境
原创/朱季谦 最近在阅读Kafka的源码，想可以在阅读过程当中，在代码写一些注释，便决定将源码部署到本地运行。 日常开发过程中，用得比较多一个版本是Kafka2.7版本，故而在MacBook Pro笔记本上用这个版本的源码进行搭建，进行Kafka源码的阅读学习。在搭建的过程当中，遇到不少坑，顺便记录 ......
Feign源码解析：初始化过程（三）
背景 前面两篇讲了下，在一个典型的引入了feign、loadbalancer、nacos等相关依赖的环境中，会有哪些bean需要创建。 其中第一篇讲了非自动配置的bean，第二篇是自动配置的bean。第一篇中提到，@FeignClient这个注解，就会创建一个beanDefinition，类型为Fe ......
源码学习 出现彻底解决unable to find valid certification path to requested target
说明：很久前spring 5.1X源码搭建成功，近阶段看源码发现更新类库出现 “：unable to find valid certification path to requested target 原因是：源码更新的是官网类库，官网需要国外我网站不能实时访问很慢，所以映射需要执行ali 服务器， ......
05 Verilog语法_过程结构与赋值
软件版本：无 操作系统：WIN10 64bit 硬件平台：适用所有系列FPGA 登录"米联客"FPGA社区-www.uisrc.com视频课程、答疑解惑！ 1概述 本节主要讲解过程结构与赋值，需要掌握阻塞和非阻塞赋值的区别。 2过程结构 过程结构语句有两种，initial 与 always 语句。它 ......
flink小记
Flink核心概念 1、Flink是为分布式、高性能、随时可用以及准确的流处理应用程序打造的开源流处理框架 2、Flink底层是以Java编写的，并为开发人员同时提供了完整的Java和Scala API。 3、Flink运行时包括JobManager（Master）和TaskManager（Work ......
python源代码加密手段 保护源码
1、编译.pyc文件 python -m py_compile info.py(py文件路径) python -m py_compile py文件绝对路径 pyc会生成在目录下的__pycache__下（前后有双下划线） 生成的文件名命名方式：源文件名.cpython-python版本.pyc 运行 ......
聊聊 从源码来看ChatGLM-6B的模型结构
基于ChatGLM-6B第一版，要注意还有ChatGLM2-6B以及ChatGLM3-6B 概述 ChatGLM是transformer架构的神经网络模型，因此从transformer结构入手，分析其源码结构。 transformer结构： 转载请备注出处：https://www.cnblogs.c ......
一对一聊天平台源码，实现幂等的8种方案
一对一聊天平台源码，实现幂等的8种方案 在一对一聊天平台源码开发时，幂等设计的基本流程都是类似的，我们简简单单来过一下幂等实现的8中方案 一、select+insert+主键/唯一索引冲突 在一对一聊天平台源码开发中，为了实现交易接口幂等，我是这样实现的：交易请求过来，我会先根据请求的唯一流水号 b ......
直播系统源码，利用重试机制保证服务稳定性
场景 在直播系统源码中有些服务依赖第三方服务或者其他服务，但有时第三方服务偶发性出现问题并且会快速的恢复，而直播系统源码可能因为这些偶发性出现问题。所以无法保证以来服务的可靠性，但是我们可以通过其他的方式来保证我们的服务是稳定的，可靠的。重试机制可以协助我们构建健壮的直播系统源码服务。比如调用第三方 ......
Mysql安装过程
Mysql安装过程 下载mysql压缩包，并解压 mysql官网下载地址 解压文件 配置 环境变量的配置 最后将解压好的mysql文件下的bin目录，如：F:\mysql\mysql-5.7.40-winx64\bin，添加上去 初始化SQL mysqld --initialize-insecure ......