Recovery默认下，一个persistent acotr在启动时会自动recover，在重启的时候回放journaled messages. 当在回放message时，被送到persistent actor的新message不会被干扰. 要等recovery完成时，新的message才会被接收到...
分类：
其他好文 时间：
2015-02-03 09:26:58
阅读次数：
184
SparkContext在获得了一系列的初始化信息后开始创建并启动TaskScheduler实例：
进入createTaskScheduler方法：
spark内核揭秘-05-SparkContext核心源码解析初体验
我们看一下其Standalone的方式：
在上述代码中首先实例化一个TaskSchedulerImpl：
然后构建出了masterUrls：
接着创建出了非常关键的backend：...
分类：
其他好文 时间：
2015-01-19 15:47:44
阅读次数：
169
user是一个actorsystem所有actor的祖先akka://HelloSystem叫做athoritypartuser/helloactor叫做pathpart打印ref后面多了一个数字，这个数字是actor的UID，就像你的***上除了你的名字又多了一个***号一样。有时，你需要与一个还没出生的actor对话，或与一个你无法联系到的actor..
分类：
其他好文 时间：
2015-01-19 00:25:36
阅读次数：
195
把akka的包加入到一个IDEAproject的类路径中akka自带了一套scala环境，加入jar包的时候注意exclude掉
分类：
其他好文 时间：
2015-01-18 08:16:24
阅读次数：
225
windows764java764scala2.10.4akka_2.10-2.3.8IDEA14.0.1
分类：
其他好文 时间：
2015-01-18 08:15:13
阅读次数：
532
Akka 设置延迟执行的Future_Patterns. after akka.pattern.Patterns.after makes it easy to complete a Future with a value or exception after a timeout. 代码如下， package?com.usoft;
import?akka.acto...
分类：
其他好文 时间：
2015-01-09 21:04:52
阅读次数：
272
Akka working with Future functionally_map方法 看代码， package?com.usoft;
import?akka.dispatch.ExecutionContexts;
import?akka.dispatch.Futures;
import?akka.dispatch.Mapper;
import?akka.dispat...
分类：
其他好文 时间：
2015-01-08 20:19:42
阅读次数：
182
Akka Actor_Future的使用 常见的是通过Actor的tell方法给另外一个actor发送消息，但是actor 和 future怎么交互，发送消息，如下， Future<Object>?future?=?Patterns.ask(a,?"are?you?ready?",?timeout);...
分类：
其他好文 时间：
2015-01-08 18:19:36
阅读次数：
261
Akka HelloWorld 示例代码， package?com.usoft;
import?akka.actor.ActorRef;
import?akka.actor.ActorSystem;
import?akka.actor.Props;
import?akka.actor.UntypedActor;
/**
?*?Created?by?liyan...
分类：
其他好文 时间：
2015-01-08 13:33:10
阅读次数：
162
