1、时间插件//日期框$('.date-picker').datepicker();2、checkbox保存checkbox的值// 组装选择的标签var check = $(".rate_checkbox input:checked"); // 得到所有被选中的checkboxvar actor_...
分类:
其他好文 时间:
2015-09-24 10:38:52
阅读次数:
197
1、测试目标:证实Akka确保Actor的每个实例都运行在自己的轻量级线程里,并拥有自己的队列,保证先进先出的处理每一条消息。 2、akka中actor既是发射器又是接收器,发消息和收消息时必经过自己的onReceive方法。 ...
分类:
编程语言 时间:
2015-09-23 10:41:30
阅读次数:
368
一、简介 于Worker Actor于,每次LaunchExecutor这将创建一个CoarseGrainedExecutorBackend流程。Executor和CoarseGrainedExecutorBackend是1对1的关系。也就是说集群里启动多少Executor实例就有多少Coarse....
分类:
其他好文 时间:
2015-09-22 20:28:22
阅读次数:
203
package com.leegh.actorimport scala.actors.Actor/** * @author Guohui Li */object First_Actor extends Actor { def act() { for (i <- 1 to 10) { ...
分类:
其他好文 时间:
2015-09-18 23:05:11
阅读次数:
226
1.包Scala包的命名方式有两种。一种和Java一样,通过把package子句放在文件顶端的方式,把整个文件的内容放进包里。如:package scala.actors.Actor 另一种方式可以在package子句之后把要放到包里的定义用花括号括起来。如:package bobsrockets{...
分类:
其他好文 时间:
2015-09-17 13:23:46
阅读次数:
134
Spark的Rpc模块是1.x重构出来可,以前的代码中大量使用了akka的类,为了把akka从项目的依赖中移除,所有添加了该模块。先看下该模块的几个主要的类使用EA把该模块所有的类都添加进来了要看懂该模块还是要先了解akka, akka有Actor和ActorRef两个类,一个用于接收消息,一个用于...
分类:
其他好文 时间:
2015-09-14 00:32:42
阅读次数:
254
akka提供了可伸缩的实时事务处理功能。akka基于actor,并提供了位置透明。1GB的heap可以有2500000个actor。水平扩展,垂直扩展,容错3个方面的解决方式。树形结构的actor,每个actor都有状态和行为。DT大数据梦工厂微信公众账号:DT_Spark。DT大数据梦工厂的微信公众号是DT_Spark..
分类:
其他好文 时间:
2015-09-12 00:59:22
阅读次数:
253
mapreduce机制在actor模式下的设计结构
分类:
其他好文 时间:
2015-09-12 00:56:29
阅读次数:
1221
对3个actor(MapActor、ReduceActor、AggregateActor)通讯的讲解。DT大数据梦工厂微信公众账号:DT_Spark。DT大数据梦工厂的微信公众号是DT_Spark,每天都会有大数据实战视频发布,请您持续学习。王家林DT大数据梦工厂scala的所有视频、PPT和代码在百度云盘的链接:http://pan.ba..
分类:
其他好文 时间:
2015-09-12 00:54:57
阅读次数:
332
actorSystem建MasterActor。akka的actor是树形结构,用ActorSystem可以用来查找分布在多台机器上的actor,也能继承一些配置到子actor。masterActor是消息的接收端和转发端。actorSystem用完要shutdown。DT大数据梦工厂微信公众账号:DT_Spark。DT大数据梦工厂的微信公众号是DT_..
分类:
其他好文 时间:
2015-09-12 00:54:03
阅读次数:
190