文章发自http://www.cnblogs.com/hark0623/p/4205756.html 转载请注明flume越用越有一些疑惑，这个月中按计划是要阅读flume源码的，我希望能解决我的疑惑，另外，当疑惑解决后，我也会把过程和结论发到博客中，最终会把链接更新至当前帖子中的，疑惑如下：1、通...
分类：
Web程序 时间：
2015-01-06 13:33:59
阅读次数：
154
接着上一篇，将分析测试程序中的访问接口部分。
2调用ZooKeeper访问接口
初始化和启动分析完了，操作接口调用代码如下：
String path = ZKPaths.makePath(PATH, name);
byte[] bytes =args[1].getBytes();
try
{
client.setData().forPath(path,bytes);
}...
分类：
其他好文 时间：
2015-01-05 00:38:17
阅读次数：
212
上一篇文章这里已经列出了Curator的一个使用的例子，这篇文章将详细分析其初始化和启动部分。
测试程序分析
1 初始化和启动
(1) newClient方法返回CuratorFramework接口对象：
public
staticCuratorFramework newClient(String connectString, int sessionTimeou...
分类：
其他好文 时间：
2015-01-05 00:37:59
阅读次数：
334
2014年12月总结：这月1号新工作开始了我的大数据之旅，从.NET转向Hadoop。工作期间遇到了解决的没有解决的有各种坑，不过好在算是把整套业务给搭建了下来。大体使用的技术及流程如下：mosquittio->flume agent->flume collector->sparkstreaming...
分类：
其他好文 时间：
2014-12-31 22:50:23
阅读次数：
208
文章来自：http://www.cnblogs.com/hark0623/p/4196381.html 转载请注明需要在你的脚本前面添加nohub，后边添加&。例如下面的脚本：nohup ./flume_client.sh &nohup的作用：当你的SecureCRT会话关闭后，保证你的脚本还在Li...
分类：
其他好文 时间：
2014-12-31 20:00:06
阅读次数：
147
从android的Surface Flinger服务启动分析知道，开机动画是在SurfaceFlinger实例通过调用startBootAnim()启动的。
下面我们就一起学习BootAnim是如何启动和结束的，我精读代码前都喜欢先描出框架图，以此图为基础再去研读会达到事半功倍的效果。好吧，直接上图。
内核起来后会启动第一个进程，即init进程。
init进程...
分类：
移动开发 时间：
2014-12-31 18:34:49
阅读次数：
12916
由于flume-ng至1.5版本仍旧没有稳定可用的类似flume-og中的taildir的功能，所以从git中https://github.com/jinoos/flume-ng-extends找了一个别人针对flume-ng实现的的taildir这个按照github上他自己说明，是没法正常使用的。...
分类：
Web程序 时间：
2014-12-29 18:07:39
阅读次数：
219
2014-12-19 01:05:42,141 (lifecycleSupervisor-1-1) [WARN - org.apache.flume.sink.AbstractRpcSink.start(AbstractRpcSink.java:294)] Unable to create Rpc ...
分类：
Web程序 时间：
2014-12-20 09:16:07
阅读次数：
461
文章来自：http://www.cnblogs.com/hark0623/p/4174646.html 转发请注明在CDH中用了几天flume后才发现，原来CDH中的flume默认是启动的…………我还自己去启动flume呢。。怪不得监听端口时告诉我端口已被占用了呢。
分类：
Web程序 时间：
2014-12-19 20:40:43
阅读次数：
170
文章来自：http://www.cnblogs.com/hark0623/p/4173714.html 转发请注明因业务需求，需要flume收集MQTT(Mosquitto)的数据。 方法就是flume自定义source，source中来订阅(subscribe)MQTTflume source的j...
分类：
Web程序 时间：
2014-12-19 14:22:28
阅读次数：
269
