在看项目代码的过程中你会发现某些代码完全可以直接用开源框架来减少代码量的,如一些带有until的工具类、一些常用的io操作等;研究发现一般的应用程序每 1,000 行代码就包含 20 到 250 个 bug!这个度量被称作缺陷密度。因此可得出一个重要的结论:更少的代码意味着更少的缺陷。个人认为在项目...
分类:
其他好文 时间:
2014-09-11 19:04:42
阅读次数:
458
spark自带的example中就有streaming结合kafka使用的案例:$SPARK_HOME/examples/src/main/scala/org/apache/spark/examples/streaming/KafkaWordCount.scala使用方法参见代码描述:Usage: ...
分类:
其他好文 时间:
2014-09-10 17:29:50
阅读次数:
219
“决胜云计算大数据时代”Spark亚太研究院100期公益大讲堂【第2期互动问答分享】Q1:新手学习spark如何入手才好?先学习Scala的内容,强烈推荐《快学Scala》;然后按照我们免费发布的“云计算分布式大数据Spark实战高手之路(共3本书)”循序渐进的学习即可,其中“云计算分布..
分类:
其他好文 时间:
2014-09-10 14:20:40
阅读次数:
211
一、什么是kafka?kafka是LinkedIn开发并开源的一个分布式MQ系统,现在是Apache的一个孵化项目。在它的主页描述kafka为一个高吞吐量的分布式(能将消息分散到不同的节点上)MQ。Kafka仅仅由7000行Scala编写,据了解,Kafka每秒可以生产约25万消息(50MB),每秒处理55万消息(11..
分类:
其他好文 时间:
2014-09-10 02:50:40
阅读次数:
342
简介 从Scala2.10.0开始提供了一种利用现有数据(变量等)创建字符串的方式--字符串插值(String Interprolation)。 字符串插值允许用户直接在字符串字面量中嵌入变量引用。下面是一个例子: scala> val name = "Jame"name: String = Jam...
分类:
其他好文 时间:
2014-09-09 21:26:09
阅读次数:
194
kestrel用的是scala,java无法直接使用。如想用java来运行kestrel,需要利用Xmemcached库。创建queue_kestrel.java# cd# mkdir test# export source_dir=~/test# vi queue_kestrel.java----...
分类:
编程语言 时间:
2014-09-09 11:04:18
阅读次数:
230
知道什么叫同步和异步吗?Insynchronousreceiving, while the server is waiting to receive data from a client, if the stream is empty the main thread will block until...
分类:
其他好文 时间:
2014-09-07 20:58:05
阅读次数:
268
Scala中的构造器相较于Java比较特殊,分为两种:主构造器,从构造器。主构造器是和类中字段和方法的定义混合在一起的。在Scala中,不需要像Java一样需要在类中定义一个与类名相同的方法来当作构造器。主构造器的参数列表写在类名的后面,而构造器的内容,则直接写在类定义里面,所以说,一个Scala类...
分类:
其他好文 时间:
2014-09-07 15:57:35
阅读次数:
213
/**
* Sets the port of the local Socks5 proxy. Default is 7777. If you set the port to a negative
* value Smack tries the absolute value and all following until it finds an open port.
...
分类:
其他好文 时间:
2014-09-07 03:18:54
阅读次数:
250
/**
* Sets the port of the local Socks5 proxy. Default is 7777. If you set the port to a negative
* value Smack tries the absolute value and all following until it finds an open port.
...
分类:
其他好文 时间:
2014-09-07 03:18:44
阅读次数:
207