有了上面的基础，我们可以来解剖DFSOutputStream了。先看构造函数： privateDFSOutputStream(String src,longblockSize, Progressable progress, intbytesPerChecksum)throwsIOException....
分类：
其他好文 时间：
2015-06-11 18:31:31
阅读次数：
113
有了上面的基础，我们可以来解剖DFSOutputStream了。先看构造函数：
privateDFSOutputStream(String
src, longblockSize,
Progressable progress,
intbytesPerChecksum) throws IOException
DFSOutputStream(String...
分类：
其他好文 时间：
2015-06-11 16:56:55
阅读次数：
211
admin包定义了命令行的一些实现一、AdminOperationException.scala一个异常类，表示执行admin命令时候抛出的异常二、AdminUtils.scalaadmin一些常用工具方法：1. assignReplicasToBrokers：负责分配副本到不同的broker上。主...
分类：
其他好文 时间：
2015-06-11 16:20:59
阅读次数：
123
目录(?)[+]=====================================================FFmpeg的库函数源代码分析文章列表：【架构图】FFmpeg源代码结构图 -解码FFmpeg源代码结构图 -编码【通用】FFmpeg源代码简单分析：av_register_al...
分类：
其他好文 时间：
2015-06-10 15:26:03
阅读次数：
162
目录(?)[+]=====================================================FFmpeg的库函数源代码分析文章列表：【架构图】FFmpeg源代码结构图 -解码FFmpeg源代码结构图 -编码【通用】FFmpeg源代码简单分析：av_register_al...
分类：
其他好文 时间：
2015-06-10 11:42:58
阅读次数：
156
从前面的图中，我们可以发现Task有很多内部类，并拥有大量类成员变量，这些类配合Task完成相关的工作，如下图。MapOutputFile管理着Mapper的输出文件，它提供了一系列get方法，用于获取Mapper需要的各种文件，这些文件都存放在一个目录下面。我们假设传入MapOutputFile的...
分类：
其他好文 时间：
2015-06-09 19:17:45
阅读次数：
130
从前面的图中，我们可以发现Task有很多内部类，并拥有大量类成员变量，这些类配合Task完成相关的工作，如下图。
MapOutputFile管理着Mapper的输出文件，它提供了一系列get方法，用于获取Mapper需要的各种文件，这些文件都存放在一个目录下面。
我们假设传入MapOutputFile的JobID为job_200707121733_0003，TaskID为task...
分类：
其他好文 时间：
2015-06-09 17:21:02
阅读次数：
117
该包下只有一个文件：ClientUtils.scala。它是一个object，里面封装了各种client(包括producer，consumer或admin)可能会用到的方法：1. fetchTopicMetadata(producer版本)： producer client会调用该方法来发送一个T...
分类：
其他好文 时间：
2015-06-09 16:42:08
阅读次数：
211
顾名思义，就是kafka的consumer api包。一、ConsumerConfig.scalaKafka consumer的配置类，除了一些默认值常量及验证参数的方法之外，就是consumer的配置参数了，比如group.id, consumer.id等，详细列表见官网。二、ConsumerIt...
分类：
其他好文 时间：
2015-06-09 15:44:20
阅读次数：
552
ChromiumFrame的入口函数在main.cpp中,打开main.cpp.中包含3个类和_tWinMain函数。_tWinMain就是我们要找的入口函数。我做了部分注释： 1 int APIENTRY _tWinMain(HINSTANCE hInstance, 2 ...
分类：
其他好文 时间：
2015-06-08 13:17:27
阅读次数：
149
