转发自玖疯的博客 http://www.cnblogs.com/lxf20061900/p/3866252.html Spark Streaming是一个新的实时计算的利器，而且还在快速的发展。它将输入流切分成一个个的DStream转换为RDD，从而可以使用Spark来处理。它直接支持多种数据源.....
分类：
Web程序 时间：
2015-10-29 13:11:47
阅读次数：
328
AvroSource简介：监听Avro端口并从外部的Avro客户端接收事件流，多个flumeagent可以通过Avro形成一个组织。PropertyName Default Descriptionchannels – type – 需要配置为Avrobind – 需要监听的主机名或ip地址port – 监听的端口threads – 工作的最大线程数selector.type..
分类：
Web程序 时间：
2015-10-28 01:47:31
阅读次数：
239
分析 MyBatis整合Spring的实现（1）中代码实现的4.2、4.3可以知道，这2个都是去生成别名管理器TypeAliasRegistry类，下面就来分析代码。 1 属性 TypeAliasRegistry类中有个Map，key为字符串，value为对应的类的C...
分类：
编程语言 时间：
2015-10-25 15:09:01
阅读次数：
274
分析 MyBatis整合Spring的实现（2）中属性可以知道，XPathParser类在XMLConfigBuilder中充当了非常重要的角色，下面就来分析XPathParser的作用。 1 属性 1.1?XPathParser属性： /**?整个XML文档?*/
private?D...
分类：
编程语言 时间：
2015-10-25 12:28:07
阅读次数：
323
作者：周邦涛(Timen)Email：zhoubangtao@gmail.com转载请注明出处: http://blog.csdn.net/zhoubangtao/article/details/28277575上一篇请參考【Flume NG用户指南】（1）设置3. 配置前边的文章已经介绍过了，Fl...
分类：
Web程序 时间：
2015-10-25 09:37:43
阅读次数：
299
package org.apache.flume.sink;import com.google.common.base.Strings;import org.apache.flume.Channel;import org.apache.flume.Context;import org.apache....
分类：
Web程序 时间：
2015-10-24 17:28:42
阅读次数：
309
细节决定成败，开发中往往从一些细节就可以看出一个程序员的开发水准，下面我就给大家分享一下开发中最最常见的int转换为String类型的方法及其性能解析。一般大家最常用的方法有方法一：String s1 = String.valueOf(i);方法二：String s2 = i+""; 不知道有没有....
分类：
其他好文 时间：
2015-10-23 11:56:00
阅读次数：
226
在Flume NG+hadoop的开发中，运行mapreduce的时候出现异常Error: java.io.IOException: Cannot obtain block length for LocatedBlock{BP-235416765-192.168.30.244-14302219675...
分类：
数据库 时间：
2015-10-21 12:25:33
阅读次数：
1198
最近公司业务数据量越来越大，以前的基于消息队列的日志系统越来越难以满足目前的业务量，表现为消息积压，日志延迟，日志存储日期过短，所以，我们开始着手要重新设计这块，业界已经有了比较成熟的流程，即基于流式处理，采用 flume 收集日志，发送到 kafka 队列做缓冲，storm 分布式实时框架进行消费...
分类：
Web程序 时间：
2015-10-15 20:36:00
阅读次数：
300
