Condition接口应用场景：一个线程因为某个condition不满足被挂起，直到该Condition被满足了。类似与Object的wait/notify，因此Condition对象应该是被多线程共享的，需要使用锁保护其状态的一致性示例代码:class BoundedBuffer { fi...
分类：
编程语言 时间：
2014-07-16 21:41:15
阅读次数：
252
Aomic数据类型有四种类型：AomicBoolean,AomicInteger,AomicLong, 和AomicReferrence(针对Object的)以及它们的数组类型，还有一个特殊的AomicStampedReferrence,它不是AomicReferrence的子类，而是利用Aomic...
分类：
编程语言 时间：
2014-07-16 21:37:41
阅读次数：
191
通过阅读 OpenJDK 源代码，描述了 Java IO 中，字节输出系列6个类的实现方式，并简单介绍了与压缩解压缩相关的几个类。...
分类：
编程语言 时间：
2014-07-13 15:51:02
阅读次数：
270
简要分析了 OpenJDK 的Java IO 中，字节流输入系列的8个类的源代码实现，给出了Java IO的基本设计思路。...
分类：
编程语言 时间：
2014-07-12 21:43:36
阅读次数：
170
欢迎转载，转载请注明出处，徽沪一郎。楔子源码阅读是一件非常容易的事，也是一件非常难的事。容易的是代码就在那里，一打开就可以看到。难的是要通过代码明白作者当初为什么要这样设计，设计之初要解决的主要问题是什么。在对Spark的源码进行具体的走读之前，如果想要快速对Spark的有一个整体性的认识，阅读Ma...
分类：
其他好文 时间：
2014-07-07 14:05:42
阅读次数：
285
稍微了解Spark源码的人应该都知道SparkContext，作为整个Project的程序入口，其重要性不言而喻，许多大牛也在源码分析的文章中对其做了很多相关的深入分析和解读。这里，结合自己前段时间的阅读体会，与大家共同讨论学习一下Spark的入口对象—天堂之门—SparkContex。SparkC...
分类：
其他好文 时间：
2014-06-28 19:27:40
阅读次数：
338
org.apache.flume.sink.AvroSink是用来通过网络来传输数据的，可以将event发送到RPC服务器（比如AvroSource），使用AvroSink和AvroSource可以组成分层结构。它继承自AbstractRpcSink extends AbstractSink implements Configurable这跟其他的sink一样都得extends Abstract...
分类：
编程语言 时间：
2014-06-24 16:01:30
阅读次数：
303
org.apache.flume.source.SpoolDirectorySource是flume的一个常用的source，这个源支持从磁盘中某文件夹获取文件数据。不同于其他异步源，这个源能够避免重启或者发送失败后数据丢失。flume可以监控文件夹，当出现新文件时会读取该文件并获取数据。当一个给定的文件被全部读入到通道中时，该文件会被重命名以标志已经完成。同时，该源需要一个清理进程来定期移除完成...
分类：
编程语言 时间：
2014-06-24 15:59:37
阅读次数：
287
OceanBase要求schema强类型约束，也就是要预先定义好schema。这与传统的数据库基本相同，与很多nosql的schema-free大相径庭。
也就是说，OceanBase的数据模式是基于关系模型的。关系模型通过关系分解消除数据结构的复杂性，获得了对数据查询的能力和灵活性。而关系模型的缺点也是因为关系分解，使得在需要“组装”的数据时要进行join操作，而join则是相当耗时的操作。
大部分的NoSQl产品以MongoDb为代表，是基于文档模型的，...
分类：
数据库 时间：
2014-06-22 14:52:00
阅读次数：
333
FileCleanTracker: 开启一个守护线程在后台默默的删除文件。 1 /* 2 * Licensed to the Apache Software Foundation (ASF) under one or more 3 * contributor license agreeme...
分类：
其他好文 时间：
2014-06-21 09:34:59
阅读次数：
324
