简介 创建线程的方式有两种，一种是实现Runnable接口，另一种是继承Thread，但是这两种方式都有个缺点，那就是在任务执行完成之后无法获取返回结果.那如果我们想要获取返...
发简信
IP属地：山西
-
java线程之FutureTask+Callable -
面试官问我如何保证Kafka不丢失消息?我哭了！
## kafka如何保证不丢消息 ps:这篇文章自我感觉说的很大白话了！希望你们看过了之后能有收获。 不了解 Kafka 的朋友建议先看一看我的下面这几篇文章，第一篇一定要...
-
消息中间件—Kafka数据存储（一）摘要：消息存储对于每一款消息队列都非常重要，那么Kafka在这方面是如何来设计做到高效的呢？Kafka这款分布式消息队列使用文件系统和操作系统的页缓存（page cache）...
-
HashMap容量为什么是2的次幂？
当容量一定是2^n时，h & (length - 1) == h % length，它俩是等价不等效的，位运算效率非常高，实际开发中，很多的数值运算以及逻辑判断都可以转换成位...
-
[spark] Shuffle Write解析 (Sort Based Shuffle)
本文基于 Spark 2.1 进行解析 前言 从 Spark 2.0 开始移除了Hash Based Shuffle，想要了解可参考Shuffle 过程，本文将讲解 Sort...
-
从B+树到LSM树，及LSM树在HBase中的应用前言 在有代表性的关系型数据库如MySQL、SQL Server、Oracle中，数据存储与索引的基本结构就是我们耳熟能详的B树和B+树。而在一些主流的NoSQL数据库如HB...
-
SparkStreaming源码之JobScheduler
SparkStreaming源码之JobScheduler篇 首先看下JobScheduler这个类是在什么时候被实例化的，打开StreamingContext代码可见： 再...
