原文： https://docs.scala-lang.org/overviews/core/futures.html 作者： Philipp Haller, Aleksandar Prokopec, Heather Miller, Viktor Klang, Roland Kuhn, and Vojin Jovanovic Introduction Future 提供了一种有效的、...

2000 年一月一日的样子我现在还记得. 自动创建索引 https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-index_.html 默认情况下, 如果操作的索引不存在会被自动创建出来, 并且应用上一个配置好的 index templates. 此外, 若果映射不存在, 索引操作也会创建一个来. 如果...

最近无意接触了AtomicInteger类compareAndSet(从JDK5开始)，搜了搜相关资料，整理了一下。 首先要说一下，AtomicInteger 类 compareAndSet 通过原子操作实现了 CAS 操作，最底层基于汇编语言实现。 简单说一下原子操作的概念，“原子”代表最小的单位，所以原子操作可以看做最小的执行单位，该操作在执行完毕前不会被任何其他任务或事件打断。...

通常来说，发布订阅（又叫 pub/sub）的特点是订阅者（listener）负责订阅频道（channel），发布者（publisher）负责向频道发送二进制字符串消息（binary string message）。每当有消息被发送给特定的频道，频道的所有订阅者都会收到消息。 命令 # 订阅一个或者多个频道 SUBSCRIBE SUBSCRIBE channel [channel ....

ByteBuf 是一个字节容器，容器里面的数据分为三个部分： 已经丢弃的字节 可读取的字节 可写入的字节 以上就是一个 ByteBuf 的结构图，从上面这幅图可以看到 ByteBuf 是一个字节容器，容器里面的的数...

Fork/Join 框架是 Java7 中新增的一项特性，也是 Java7 平台的其中一项主要改进。 在实际情况中，很多时候我们都需要面对经典的“分治”问题。要解决这类问题，主要任务通常被分解为多个任务块（分解阶段），其后每一小块任务被独立并行计算。一旦计算任务完成，每一快的结果会被合并或者解决（解决阶段）。 “分治”问题可以很容易地通过 Callable 线程的 Executor 接口...

全文参考： spring boot 配置 freemarker pom.xml <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot...

Requirements The only requirements are working Maven 3.0.4 (or higher) and Java 8.x installations. 官网 https://flink.apache.org/ Create Project 使用 maven 命令: $ mvn archetype:generate ...

Channel Socket ChannelHandler ChannelHandler 的典型用途包括： 将数据从一种格式转换为另一种格式。 提供异常的通知。 提供 Channel 变为活动的或非活动的通知。 提供当 Channel 注册到 EventLoop 或者从 EventLoop 注销时的通知 提供有关用户自定义的通知 Channel 的方法：...

Spark SQL 提供了一下三大功能： 从结构化数据源（JSON、Hive、Parquet）中读取数据 使用 SQL 语句进行查询 SQL 和代码整合 为实现这些功能，Spark SQL 提供了一种特殊的 RDD 叫 SchemaRDD。SchemaRDD 是存放 Row 对象的 RDD，每个 Row 对象代表一行记录。 SchemaRDd 还包含记录的结构信息（...