
spark 0.2版本与0.1版本相比较,RDD增加了groupBy算子,并丰富了PariRDD的算子(reduceByKey、combineByKey、groupByKey...
Spark 0.1是spark开源的第一个版本,本文主要从组成类、如何触发执行、如何具体执行这几个方面进行分析。 主要组成类: 1.RDD,其中RDD主要包含两种类型的函数,...
20年朝九晚五的IT生涯。羡慕啊!
一个艰难的决定辞职信开头的套话往往会写It is a hard decision……甭管心里是真纠结,还是高兴得快要飞起。 然而,对我来说,这一次,真的不是套话。 艰难并不在于要辞去眼前的...
ConcurrentHashMap简介: ConcurrentHashMap是线程安全且高效的HashMap,使用锁分段技术提高并发访问率; ConcurrentHashMa...
基本概念: 锁:控制多线程并发访问资源;队列同步器:管理同步状态,实现锁;同步状态:同步器的操作对象,int类型;同步队列:同步器通过同步队列管理同步状态; 同步器实现锁: ...
线程的优先级: 线程的优先级越高,占用CPU的能力越强; 线程中断: 调用线程对象的interrupt()函数后,线程并不会立即中断,而是将线程的中断标识设为true,只有遇...
上下文切换: CPU切换线程时就产生了一次上下文切换; Java如何实现原子操作: 锁和CAS操作; happens-before规则:前一个操作的结果对后一个操作可见 一个...
题目 题目内容 实现一个基于发布/订阅模型的消息中间件,功能要求如下: broker保证消息落盘后才向producer返回发送成功的ack,并把消息推送给consumer; ...
题目 题目内容 Topic类似于水坝(蓄积功能,消峰填谷之利器),Queue类似于水渠;每当新建一个Queue的时候,可以选择绑定到几个Topic,类似于水渠从水坝引水; 每...
问题描述:线上新上项目没有生成日志文件,看tomcat下logs里的日志报 05-May-2017 14:58:31.205 WARNING [RMI TCP Connect...