码迷,mamicode.com
首页 >  
搜索关键字:flume hdfseventsink 实现分析    ( 1426个结果
GPU的革命
CUDA 线程执行模型分析(一)招兵------ GPU的革命CUDA 线程执行模型分析(二)大军未动粮草先行------GPU的革命CUDA硬件实现分析(一)------安营扎寨-----GPU的革命CUDA硬件实现分析(二)------规行矩步------GPU的革命CUDA编程接口(一)---...
分类:其他好文   时间:2015-03-07 18:29:45    阅读次数:182
flume HDFSEventSink实现分析
HDFSEventSink用于把数据从channel中拿出来(主动pull的形式)然后放到hdfs中,HDFSEventSink在启动时会启动两个线程池callTimeoutPool和timedRollerPool,callTimeoutPool用于运行append/flush等操作hdfs的task(通过callWithTimeout方法调用,并实现timeout功能),用于运行..
分类:Web程序   时间:2015-03-06 06:24:34    阅读次数:254
flume的各个组件及整体工作流程
flume的主要组件包括:Source,SourceRunner,Interceptor,Channel,ChannelSelector,ChannelProcessor,Sink,SinkRunner,SinkProcessor,SinkSelector等工作流程包含两个部分:source->channel,数据由source写入channel,主动模式,主要步骤如下:一个SourceRunner包含一个So..
分类:Web程序   时间:2015-03-06 06:24:30    阅读次数:217
【HDFS】HDFS的整体架构设计,阅读笔记
以上是该命令的选项 [root@com22 bin]# sh hdfs fsck /flume/events/2015/03/02/13 -racks Connecting to namenode via http://com22.authentication:50070 FSCK started by root (auth:SIMPLE) from /192.168.11.177 fo...
分类:其他好文   时间:2015-03-05 17:10:00    阅读次数:120
【Flume】flume输出sink到hbase的实现
flume 1.5.2 hbase 0.98.9 hadoop 2.6 zk 3.4.6 以上是基础的软件及对应版本,请先确认以上软件安装成功! 1、添加jar包支持 将hbase的lib下的这些jar包拷贝到flume的lib下 2、配置flume 注意看以上的serializer配置,采用的是官方的RegexHbaseEventSerializer, ...
分类:Web程序   时间:2015-03-04 11:05:56    阅读次数:258
flume transaction实现
flume作为日志收集端,其本质上也是一个生产者消费者结构,source作为消息的producer,sink作为消息的consumer,中间的channel作消息的存储为了保证消息消费的正确性,flume使用了事务的机制,主要涉及的类:1)org.apache.flume.Transaction接口类,为访问channel提供事务的功..
分类:Web程序   时间:2015-03-04 06:22:18    阅读次数:282
flume channel monitor实现
对于flume的监控,只需要监控channel的性能数据即可,source和sink的性能一部分可以从channel中表现出来。以MemoryChannel为例,在MemoryTransaction的构造函数中会实例化一个org.apache.flume.instrumentation.ChannelCounter对象publicMemoryTransaction(inttransCapacity,Ch..
分类:Web程序   时间:2015-03-04 06:22:07    阅读次数:250
flume SinkProcessor 相关类实现分析
org.apache.flume.SinkProcessor扩展了LifecycleAware,Configurable接口的接口类,操作多个sink的抽象层(类似于proxy),用来分配给SinkRunner对象抽象方法:process和Sink的process方法类似(内部实现增加了选择Sink的功能)setSinks设置sinks具体实现类:org.apache.flume.s..
分类:Web程序   时间:2015-03-04 06:18:28    阅读次数:206
[转] TCP数据包重组实现分析
PS: 这个实现对于某些特定情况未必是最佳实现,可以用数组来代替队列来实现参照TCP/IP详解第二卷24~29章,详细论述了TCP协议的实现,大概总结一下TCP如何向应用层保证数据包的正确性、可靠性,即TCP如何实现对数据报文的重组。首先要设计两个报文队列,一个存放正常来到的报文,一个存放失序到来的...
分类:其他好文   时间:2015-03-03 11:21:25    阅读次数:139
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!