码迷,mamicode.com
首页 >  
搜索关键字:flume hdfseventsink 实现分析    ( 1426个结果
flume-ng安装和简单使用例子
1.安装jdk。 2.下载解压flume,修改bin/netcat-memory-logger.conf,内容如下: agent1.sources?=?sources1 agent1.channels?=?channels1? agent1.sinks?=?sinks1 agent1.sources.sources1.type?=?netca...
分类:Web程序   时间:2015-09-24 17:54:37    阅读次数:416
UDT协议实现分析——UDT数据收发的可靠性保障
不管是数据的发送还是数据的接收,大体的流程我们基本上是都理了一下,还分析了数据收发过程中用的数据结构,接下来就看一些UDT中数据收发更精细的一些控制。 UDT数据收发的可靠性保障 来看一下UDT中数据收发的可...
分类:其他好文   时间:2015-09-23 21:18:53    阅读次数:871
UDT协议实现分析——数据的接收
看了UDT中数据发送的部分之后,我们转换一个角度,来看一下接收端发生的故事。 如我们前面在 UDT协议实现分析——连接的建立 一文中看到的那样,CUDT在connect()的后半场,会通过调用CRcvQueue::removeConnector(...
分类:其他好文   时间:2015-09-21 21:28:04    阅读次数:599
选择用户-保存选定的用户
1介绍功能要求:1 选择用户界面以弹出框方式显示2 页面选项动态载入(部门及用户)3 保存勾选的用户实现分析:保存已选用户逻辑:删除原来已选择的用户记录列表(相当于清空操作)加入新选择用户记录列表页面1 保存共享文件// 保存共享文件 function shareFile(){ ...
分类:其他好文   时间:2015-09-18 21:48:34    阅读次数:151
UDT协议实现分析——数据发送控制
在前文中,我们有看到,数据发送的过程,大体是发送者CUDT将要发送的数据放进它的CSndBuffer m_pSndBuffer,并将它自己添加进它的CSndQueue m_pSndQueue的CSndUList m_pSndUList的堆里,后面CSndQueue m_pSndQue...
分类:其他好文   时间:2015-09-18 20:37:46    阅读次数:1125
UDT协议实现分析——数据的发送
连接建立起来之后,我们就可以通过UDT Socket进行数据的收发了。先来看用来发送数据的几个函数。UDT提供了如下的几个函数用于不同目的下的数据发送: UDT_API int send(UDTSOCKET u, const char* buf, int len, ...
分类:其他好文   时间:2015-09-14 19:45:37    阅读次数:193
UDT协议实现分析——连接的建立
UDT Server在执行UDT::listen()之后,就可以接受其它节点的连接请求了。这里我们研究一下UDT连接建立的过程。 连接的发起 来看连接的发起方。如前面我们看到的那样,UDT Client创建一个Socket,可以将该Socket绑定...
分类:其他好文   时间:2015-09-12 12:20:20    阅读次数:1601
0909编译原理作业
1.学习编译原理既掌握编译理论和方法方面的基本知识,而且也获得设计、实现、分析和移植编译程序方面的初步能力。知道程序编译器是怎么编译的,学好了以后可以开发编译器。学会使自己写的程序更优,提高程序的效率。告诉我们编译器是怎么在内存中为程序的函数(包括变量)分配空间的等等。 2.编译原理是计算机专业设置...
分类:其他好文   时间:2015-09-11 19:13:38    阅读次数:149
Flume的安装与配置
Flume的安装与配置一、 资源下载资源地址:http://flume.apache.org/download.html程序地址:http://apache.fayea.com/flume/1.6.0/apache-flume-1.6.0-bin.tar.gz源码地址:http://mirrors....
分类:Web程序   时间:2015-09-10 17:19:06    阅读次数:244
Spark入门实战系列--7.Spark Streaming(下)--Spark Streaming实战
Spark Streaming 是Spark核心API的一个扩展,可以实现高吞吐量的、具备容错机制的实时流数据的处理。支持从多种数据源获取数据,包括Kafk、Flume、Twitter、ZeroMQ、Kinesis 以及TCP sockets,从数据源获取数据之后,可以使用诸如map、reduce、join和window等高级函数进行复杂算法的处理。最后还可以将处理结果存储到文件系统,数据库和现场仪表盘。...
分类:其他好文   时间:2015-09-10 11:10:49    阅读次数:212
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!