Flink源码分析系列文档目录 请点击:Flink 源码分析系列文档目录[https://www.jianshu.com/p/d4a372809e3d] 启动脚本分析 Tas...
Flink源码分析系列文档目录 请点击:Flink 源码分析系列文档目录[https://www.jianshu.com/p/d4a372809e3d] 启动脚本分析 Tas...
Disruptor核心源码分析 说来惭愧,Log4j2的异步日志已经用了将近2年时间了。但是每次想看Disruptor源码的时候,总是没能坚持下去。这次通过一次生产环境的故障...
HBase的源码: 1、集群启动master启动regionsever启动2、put 插入数据源码分析delete3、get 查询数据源码分析scan4、三个重要的行为:fl...
1.Reactor模式介绍 Reactor模式是事件驱动模型,有一个或多个并发输入源,有一个Service Handler,有多个Request Handlers;这个Ser...
背景 MapReduce不能满足大数据快速实时adhoc查询计算的性能要求,Facebook2012年开发,2013年开源 是什么 基于内存的并行计算,Facebook推出的...
流程 流程讲解 在我们通过代码send消息之后,这条消息就会发往拦截器Interceptor Interceptor会对数据做处理加解密/脱敏过滤不满足条件的数据(ip白名单...
努力做程序员中的标题党,这个文章的副标题 面向JIT编程-方法内联 JIT的全称是Just in time compilation,中文称之为即时编译。JIT是JVM最强大的...
一、 更改目录操作 该操作基本只和NameNode进行交互 rename/mkdir等操作 NameNode在目录树数据结构上对应位置创建新的目录节点并持久化到日志中。 de...
背景 yarn默认使用的是最简单的FIFO调度器,即一个default队列,所有用户共享,分配资源也是先到先得,没有优先级之分。有时一两个任务就把资源全占了,其他任务吃不到资...