文章分类
Java基础
java基础
Map
算法
计算机原理
队列
AQS与同步锁
线程与线程池
IO与网络
java代理
jdbc及其扩展
单元化测试
读书笔记
《spring源码深度解读》
《深入理解JAVA虚拟机》
《MySQL是怎样运行的:从根上理解MySQL》
《Redis开发与运维》
《算法4》
《Java并发编程的艺术》
《Docker与容器云》
中间组件
数据库
大数据组件
分布式
缓存
消息组件
运维基础
技术实践
项目源码
com.alibaba.druid
jedis
commons-lang3
java.security
apache.httpclient
java.io
apache.commons.pool2
tomcat
apache.sshd
json
lombok.log4j2
mybatis
netflix.archius
前端知识
瞬间
相册
朋友圈
留言板
友情链接
沧海月明
解决了什么问题,做了什么优化
累计撰写
166
篇文章
累计创建
38
个标签
累计收到
1
条评论
栏目
文章分类
Java基础
java基础
Map
算法
计算机原理
队列
AQS与同步锁
线程与线程池
IO与网络
java代理
jdbc及其扩展
单元化测试
读书笔记
《spring源码深度解读》
《深入理解JAVA虚拟机》
《MySQL是怎样运行的:从根上理解MySQL》
《Redis开发与运维》
《算法4》
《Java并发编程的艺术》
《Docker与容器云》
中间组件
数据库
大数据组件
分布式
缓存
消息组件
运维基础
技术实践
项目源码
com.alibaba.druid
jedis
commons-lang3
java.security
apache.httpclient
java.io
apache.commons.pool2
tomcat
apache.sshd
json
lombok.log4j2
mybatis
netflix.archius
前端知识
瞬间
相册
朋友圈
留言板
友情链接
目 录
CONTENT
以下是
FatFish1
的文章
2025-08-08
mysql中的不常用sql及命令
远程后台登录 mysql -h [ip] -P [port] -u [username] -p [password] 创建database CREATE DATABASE [dbname] CHARACTER SET utf8 COLLATE utf8_general_ci; 查指定分区数据
2025-08-08
3
0
0
数据库
2025-08-06
apache.Flink - prcess函数
Process方法和ProcessFunction 在 Apache Flink 中,ProcessFunction 是一个低层次、功能强大的流处理 API,它提供了对数据流处理的细粒度控制。它是构建更复杂流处理逻辑的基础工具,主要作用包括: 复杂事件处理:例如,需要跨多个事件进行状态跟踪(如会话窗
2025-08-06
1
0
0
大数据组件
2025-08-06
HBase
HBase的基础知识 HBase 是大数据领域解决海量数据实时读写挑战的核心组件之一,它的特性包括: 分布式、可扩展性、高可用:HBase节点分为HMaster和RegionServer HMaster负责元数据管理和Region分配,其可以通过主备架构搭建,基于ZK进行节点选举 RegionSer
2025-08-06
1
0
0
大数据组件
2025-07-22
大数据组件的常用命令
Yarn 查看yarn日志:yarn logs <applicationid> HDFS hdfs检索对应目录:hdfs dfs -ls <HDFSpath> hdfs上传文件到对应目录:hdfs dfs -put /opt/test.txt <HDFSpath> Hive 创建表:create t
2025-07-22
2
0
0
大数据组件
2025-07-21
Zookeeper
Zookeeper的能力 Zookeeper是一个开源的、高性能的分布式协调服务
2025-07-21
2
0
0
大数据组件
分布式
2025-07-18
排序
选择排序 假设有一个数组nums,长度为n,想要将其从小到大排序,选择排序的思路是: 从1 ~ n数据中选择最小的,与nums[0]交换 从2 ~ n数据中选择最小的,与nums[1]交换 …… 选择排序的实现核心是:双层for循环+暂存minIndex+交换
2025-07-18
1
0
0
《算法4》
算法
2025-07-18
stream
【案例1 处理stuff成result,对result做groupby】 Map<Result, List<Stuff>> collect = stuffs.stream().map(stuff -> { Result result = doProcess(stuff); retu
2025-07-18
4
0
0
java基础
2025-07-09
apache.Flink - 时间和窗口
Flink中的时间语义 事件时间和处理时间 为什么要研究Flink中的时间意义? 对于一个流式系统,要求数据处理实时性,尤其是Flinkh中的keyBy操作,如果要求对时间做分类,例如处理8~9点的数据,就可能产生如下场景: 一条数据生成是8:59:59,到达Flink节点1的时间是9:00:01,
2025-07-09
4
0
0
大数据组件
2025-07-07
【实践】pulsar+flink流式架构
目标:搭建一个简单的流式框架,处理Pulsar中topicA的信息,处理后转发至topicB,其中: topicA中的一条message是一行行数据组成的list 处理后的结果应该是一行数据对应一个HandleResult,也以一条message的形式下发 构建FLink项目 引入pom依赖 <pr
2025-07-07
3
0
0
大数据组件
技术实践
2025-07-07
apache.Flink - 富含数类、sink算子
富含数类 map算子、Filter算子、reduce算子等都可以使用富含数类作为算子,富含数类是增强型函数接口,为数据处理逻辑提供了生命周期管理和状态访问能力。它们是构建复杂流处理应用的关键基础 富函数类一般以抽象类形式存在,例如RichMapFunction、RichFilterFunction、
2025-07-07
4
0
0
大数据组件
1
2
3
4
5
...
17