码迷,mamicode.com
首页 >  
搜索关键字:flume sinkprocessor 源码分析    ( 6696个结果
Flume 实战,将多台机器日志直接收集到 Kafka
目前我们使用的一个 b 端软件的报错日志分散在集群各处,现在想把它收集到一个地方然后统一丢进 Kafka 提供给下游业务进行消费。 我想到了 flume,之前让同事搭建的这次自己想多了解一些细节于是就开搞了。 首先还是下载 flume 的客户端,这里我使用最新版本 1.9.0 设置需要的 java ...
分类:Web程序   时间:2019-11-15 18:26:10    阅读次数:89
集合家族——ArrayList
一、概述: ArrayList 是实现 List 接口的动态数组,所谓动态就是它的大小是可变的。实现了所有可选列表操作,并允许包括 null 在内的所有元素。除了实现 List 接口外,此类还提供一些方法来操作内部用来存储列表的数组的大小。 二、源码分析: 底层是Object类型数组,增删很慢,查询 ...
分类:其他好文   时间:2019-11-15 14:00:48    阅读次数:97
flume源码
IDEA查看源码 IDEA快捷键 1 查看接口的实现类:Ctrl+Alt+B 选中按快捷键,然后跳到实现类的地方去 2 切换页面:Alt+<- 和 Alt+-> Alt+-> 3 查看Java方法调用树(被调/主调):Ctrl+Alt+H 分为调用当前方法的树、当前方法调用的下级方法 4 查看类继承 ...
分类:Web程序   时间:2019-11-15 12:15:04    阅读次数:91
MapReduce任务提交源码分析
为了测试MapReduce提交的详细流程。需要在提交这一步打上断点: F7进入方法: 进入submit方法: 注意这个connect方法,它在连接谁呢?我们知道,Driver是作为客户端存在的,那么客户端连接的应该就是Yarn集群,但是在这个简单的WordCount案例中,并没有将任务提交到Yarn ...
分类:其他好文   时间:2019-11-13 22:01:42    阅读次数:85
springIOC源码接口分析(四):MessageSource
一 定义方法 二 测试 ...
分类:编程语言   时间:2019-11-12 18:38:26    阅读次数:77
flask框架(三)——路由系统route转换成add_url_rule及源码分析
这节我们不用@app.route来写路由,而是通过add_url_rule 典型写法 (<int:nid>传递int类型参数,endpoint是取别名) @app.route('/detail/<int:nid>',methods=['GET'],endpoint='detail') 默认转换器 D ...
分类:Web程序   时间:2019-11-11 21:35:08    阅读次数:95
SpringBoot自动装配流程源码分析
SpringBoot传统方式的SSM框架因为需要配置大量文件而被开发人员诟病重复性工作,所以SpringBoot的出现在减少开发人员做大量重复性配置的工作,使得开发人员能够快速的开始项目开发、更加专注于业务代码的编写。但SpringBoot跟SSM有什么框架不同呢?为什么SpringBoot可以自动装配呢?SpringBoot自动装配是如何实现的呢?SpringBoot入口写过SpringBoot
分类:编程语言   时间:2019-11-11 17:02:28    阅读次数:101
5. SOFAJRaft源码分析— RheaKV中如何存放数据?
概述 上一篇讲了RheaKV是如何进行初始化的,因为RheaKV主要是用来做KV存储的,RheaKV读写的是相当的复杂,一起写会篇幅太长,所以这一篇主要来讲一下RheaKV中如何存放数据。 我们这里使用一个客户端的例子来开始本次的讲解: 我们从这个main方法中启动我们的实例,调用rheaKVSto ...
分类:其他好文   时间:2019-11-10 17:19:11    阅读次数:89
多线程并发编程总结(二)
本文基于 "https://github.com/h2pl/Java Tutorial" 的总结 ReentrantReadWriteLock(读写锁)源码分析 "BlockingQueu 阻塞队列" ArrayBlockingQueue(数组。有界) LinkedBlockingQueue(链表。 ...
分类:编程语言   时间:2019-11-10 14:00:04    阅读次数:89
Mybaits 源码解析 (九)----- 全网最详细,没有之一:一级缓存和二级缓存源码分析
在实际项目中,我们发现在一个事务中查询同样的语句两次的时候,第二次没有进行数据库查询,直接返回了结果,实际这种情况我们就可以称为缓存。 Mybatis的缓存级别 一级缓存 MyBatis的一级查询缓存(也叫作本地缓存)是基于org.apache.ibatis.cache.impl.Perpetual ...
分类:其他好文   时间:2019-11-09 17:11:50    阅读次数:99
6696条   上一页 1 ... 72 73 74 75 76 ... 670 下一页
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!