org.apache.flume.sink.AvroSink是用来通过网络来传输数据的，可以将event发送到RPC服务器（比如AvroSource），使用AvroSink和AvroSource可以组成分层结构。它继承自AbstractRpcSink
extends AbstractSinkim.....
分类：
其他好文 时间：
2014-06-29 14:29:54
阅读次数：
392
自从建了Spark交流的QQ群之后，热情加入的同学不少，大家不仅对Spark很热衷对于Storm也是充满好奇。大家都提到一个问题就是有关storm内部实现机理的资料比较少,理解起来非常费劲。尽管自己也陆续对storm的源码走读发表了一些博文，当时写的时候比较匆忙，有时候衔接的不是太好，此番做了一些整...
分类：
其他好文 时间：
2014-05-30 07:25:09
阅读次数：
286
在AbstractConfigurationProvider类中loadSources方法会将所有的source进行封装成SourceRunner放到了Map
sourceRunnerMap之中。相关代码如下： 1 Map selectorConfig = context.getSu...
分类：
其他好文 时间：
2014-05-27 15:57:09
阅读次数：
347
ThinkPHP访问流程在手册1.11系统流程里就有介绍,我阅读的ThinkPHP的版本是3.1.3,大家可以看下手册,基本的流程也有,现在就是详细去介绍一下ThinkPHP的访问流程.(调试模式下的,在部署模式下,会把中间的URL解析,文件加载之类的,都封装到一个文件里)1.入口文件(index.php)入口文件..
分类：
Web程序 时间：
2014-05-27 03:34:01
阅读次数：
266
在AbstractConfigurationProvider类中loadSinks方法会调用loadSinkGroups方法将所有的sink和sinkgroup放到了Map
sinkRunnerMap之中。 SinkRunner可能对应一个sink也可能对应一个sinkgroup。因为如果配置...
分类：
其他好文 时间：
2014-05-25 22:05:04
阅读次数：
398
阅读本节内容前可先了解 apkplug基础教程
本教程是基于apkplug V1.6.8 版本编写 最新开发方式以官网为准
可下载最新的apkplugdemo源码http://git.oschina.net/plug/apkplugDemos
apkplugdemo演示图
一 apkplugdemo工程源码结构
src
|-c...
分类：
移动开发 时间：
2014-05-22 06:43:59
阅读次数：
373
ThinkPHP的核心采用的框架模式是CBD,也就是核心Core+行为Behavior+驱动Driver,核心也就是整个框架模式的核心,大部分都是一些基类,去规定规则,Behavior是行为,就是在指定的地方调用来完成一些特定的行为功能,而Driver驱动就类似cache缓存驱动,mysqldb数据库驱动等,完成功能行为..
分类：
Web程序 时间：
2014-05-20 22:45:40
阅读次数：
456
ThinkPHP的配置非常灵活,可自定义加载.大概看了一下,一共有这几个地方会加载配置文件,方便以后的读取/**
*获取和设置配置参数支持批量定义
*
*@paramstring|array$name
*配置变量
*@parammixed$value
*配置值
*@returnmixed
*/
functionC($name=null,$value=null){
static$_con..
分类：
Web程序 时间：
2014-05-20 20:13:46
阅读次数：
347
FileChannel是flume一个非常重要的channel组件，非常常用。这个channel非常复杂，涉及的文件更多涉及三个包：org.apache.flume.channel.file、org.apache.flume.channel.file.encryption(加密)、org.apa.....
分类：
其他好文 时间：
2014-05-19 13:02:06
阅读次数：
285
推荐的源码阅读工具为: vim + ctags +
cscopeLinux源代码提供了制作cscope索引文件和tags文件的make命令。一，软件安装先安装cscope：sudo apt-get install
cscope再安装ctags：sudo apt-get install ctags二，...
分类：
其他好文 时间：
2014-05-14 03:58:50
阅读次数：
329
