在AbstractConfigurationProvider类中loadSources方法会将所有的source进行封装成SourceRunner放到了Map
sourceRunnerMap之中。相关代码如下： 1 Map selectorConfig = context.getSu...
分类：
其他好文 时间：
2014-05-27 15:57:09
阅读次数：
347
写在前面一：
本文总结“Hadoop生态系统”中的其中一员——Apache Flume
写在前面二：
所用软件说明：
一、什么是Apache Flume
官网：Flume is a distributed, reliable, and available
service for efficiently
collecting, aggregating, and m...
分类：
其他好文 时间：
2014-05-26 04:32:10
阅读次数：
359
出题：要求层序遍历二叉树，从上到下的层次，每一层访问顺序为从左到右，并将节点一次编号，输出如下；如果只要求打印指定的level的节点，应该如何实现。 a b c
d e f g h i分析：原始的层序遍历类似于BFS，打印当前访问的节点curNode的序列号，并将其直接子节点放入队列queu...
分类：
其他好文 时间：
2014-05-25 22:22:45
阅读次数：
321
在AbstractConfigurationProvider类中loadSinks方法会调用loadSinkGroups方法将所有的sink和sinkgroup放到了Map
sinkRunnerMap之中。 SinkRunner可能对应一个sink也可能对应一个sinkgroup。因为如果配置...
分类：
其他好文 时间：
2014-05-25 22:05:04
阅读次数：
398
在已经成功安装Flume的基础上，本文将总结使用Flume进行数据的实时收集处理，具体步骤如下：
第一步，在$FLUME_HOME/conf目录下，编写Flume的配置文件，命名为flume_first_conf，具体内容如下：
#agent1表示代理名称
agent1.sources=source1
agent1.sinks=sink1
agent1.channels=channel1...
分类：
其他好文 时间：
2014-05-25 00:49:58
阅读次数：
383
曾几何时，只是一直在调用库函数fork,只知道它创建一个子进程，并且子进程返回值是0，父进程返回值是子进程pid。但是一直没有深究内核代码，今天终于使用gdb调试了一把fork的内核代码，下面就让我们一探究竟吧。
1.创建进程的本质是什么？
根据目前理解，其实就是构造了PCB，这个PCB会唯一标示一个进程的存在，并且会构建子进程的页目录和页表等等。
2.为什么fork()调用会有2个返回值，...
分类：
系统相关 时间：
2014-05-22 10:40:01
阅读次数：
404
谈到httpclient的话，只要会想到apache的httpclient和jetty的httpclient，但是apache的httpclient3和4之间又有区别，通过学些，最终总结了三种方式使用HttpClient，分别为使用httpclient3，httpclient4，jetty的httpclient，下面分别来贴代码：第1种：使用的jar包为commons-htt..
分类：
其他好文 时间：
2014-05-21 00:39:41
阅读次数：
296
项目中用到了jettycontinuation，但是一直不知道continuation到底有什么作用，下面这个文章讲解的很清楚，附上自己的一点见解：1.http请求的处理逻辑是什么？当一个HTTP请求到来的时候，server分配一个单独的线程处理这个请求，请求完成之后再返回response给请求端。这个过程中..
分类：
其他好文 时间：
2014-05-20 18:22:18
阅读次数：
1604
FileChannel是flume一个非常重要的channel组件，非常常用。这个channel非常复杂，涉及的文件更多涉及三个包：org.apache.flume.channel.file、org.apache.flume.channel.file.encryption(加密)、org.apa.....
分类：
其他好文 时间：
2014-05-19 13:02:06
阅读次数：
285
Epoll实现分析——作者：lvyilong316
通过上一章分析，poll运行效率的两个瓶颈已经找出，现在的问题是怎么改进。首先，如果要监听1000个fd，每次poll都要把1000个fd 拷入内核，太不科学了，内核干嘛不自己保存已经拷入的fd呢？答对了，epoll就是自己保存拷入的fd，它的API就已经说明了这一点——不是 epoll_wait的时候才传入fd，而是通过epoll_ctl...
分类：
其他好文 时间：
2014-05-13 13:38:54
阅读次数：
321
