此题考查的是线程间的通信方式。 可以利用park/unpark实现 可以利用volatile关键字实现 可以利用synchronized结合wait notify实现 可以利用JUC中的CountDownLatch实现 可以利用Condition中的await signal 实现 代码示例 利用Pa ...
分类：
编程语言 时间：
2019-12-24 23:40:45
阅读次数：
156
https://stackoverflow.com/questions/52659109/cannot read from elasticsearch using pyspark https://stackoverflow.com/questions/35982550/how to read dat ...
分类：
其他好文 时间：
2019-12-23 18:29:41
阅读次数：
104
1、RpcEndpoint: RPC端点 Spark针对每个节点（Client、Master、Worker）都称之为一个RpcEndpoint，且都实现RpcEndpoint接口，内部根据不同端点的需求，设计不同的消息和不同的业务处理，如果需要发送（询问）则内部调用Dispatcher的对应方法 说 ...
分类：
Web程序 时间：
2019-12-22 14:19:28
阅读次数：
120
第1章 课程介绍&学习指南本章会对这门课程进行说明并进行学习方法介绍。第2章 Redis入门Redis是目前最火爆的内存数据库之一，通过在内存中读写数据，大大提高了读写速度。本章将从Redis特性、应用场景出发，到Redis的基础命令，再到Redis的常用数据类型实操，最后通过Java API来操作 ...
分类：
其他好文 时间：
2019-12-22 10:59:01
阅读次数：
839
AQS AbstractQueuedSynchronizer抽象资源队列同步器，用于实现任务对于资源获取的同步功能。 几个要点： 资源：state，int计数 等待线程：Node，等待线程队列 线程阻塞：Unsafe.park() 获取和释放资源通过操作state实现，为0则代表资源空闲。 ...
分类：
其他好文 时间：
2019-12-20 18:29:35
阅读次数：
65
CC 03The game rock, paper, scissors is a classic tool used to make important decisions among two friends (read https://www.wikihow.com/Play-Rock,-Pape ...
分类：
编程语言 时间：
2019-12-19 13:01:43
阅读次数：
79
今天服务器突然出现如下告警 XFS （dm-0）：Please umount the filesystem and rectify the problem(s) 因为dm-0是系统根目录的映射，所以需要修复根目录 话不多说，直接挂盘，然后进入救援模式 这里选第3个选项，进去查看根目录的分区，因为做系 ...
分类：
其他好文 时间：
2019-12-18 10:38:37
阅读次数：
310
from pyspark import SparkContext Traceback (most recent call last): File "<stdin>", line 1, in <module> 要先安装 findspark 包 然后执行 pip install findsparp 再进 ...
分类：
编程语言 时间：
2019-12-15 14:44:20
阅读次数：
206
一、测试数据集(奥特曼.json) 二、源代码 1 import org.apache.spark.sql.SparkSession 2 3 //在Scala中,样例类在编译时会默认实现Product特质 4 case class Ultraman(name: String, age: BigInt ...
分类：
数据库 时间：
2019-12-14 17:35:20
阅读次数：
144
一、Kafka简介 Kafka是一种高吞吐量的分布式发布订阅消息系统，用户通过Kafka系统可以发布大量的消息，同时也能实时订阅消费消息。Kafka可以同时满足在线实时处理和批量离线处理。 在公司的大数据生态系统中，可以把Kafka作为数据交换枢纽，不同类型的分布式系统（关系数据库、NoSQL数据库 ...
分类：
其他好文 时间：
2019-12-12 13:28:15
阅读次数：
155
