Tuple2(二元组)Tuple3(三元组) flatmap，也就是将嵌套集合转换并平铺成非嵌套集合 Flink适用场景 典型的事件驱动型应用实例 反欺诈 异常检测 基于规则...
IP属地：上海
-
基于Flink实现开发能力监控平台
-
为人民服务
-
系统监控-Metric
Metrics is a Java library which gives you unparalleled insight into what your code does...
-
Cassandra集群优化与运维
集群部署 Cassandra集群的性能与其规模线性正相关。可以说Cassandra在目前流行的开源分布式中间件中，设计最为优雅，架构堪称完美，没有之一。在苹果公司内部Cass...
-
努力工作，为团队和社会发展献出绵薄之力。守正笃实、久久为功。
-
Guava之EventBus源码最近需要使用事件驱动，打算使用EventBus管理事件的注册和分发。于是仔细阅读了下Guava的EventBus实现，并在此做了些整理。EventBus是基于设计模式中的Ob...
-
Cassandra源码阅读（未完成）SEDA Cassandra 的操作使用的并发模型。SEDA将应用程序分解为由事件队列分隔的各个阶段，并引入动态资源控制器的概念，允许应用程序动态调整，不断适应变化的负载。它...
-
Lake Khanka is a freshwater lake on the border between Primorsky Krai, Russia and Heilongjiang province, China. <br>Akka is the name of a beautiful mountain(that Jonas climbed and skied some years age) in the Laponia region in Northern Sweden. The mountain is also sometimes called 'The Queen of Laponia'. Akka is also the name of a goddness in the Sami(the native Swedish population)mythology. She is the goddness that stands for all the beauty and good in the world. The mountain can be seen as the symbol of this goddness. Also,the name AKKA is the palindrome of letters A and K as in Actor Kernel and returns very few hits on Google.
-
-
Java并发系列7-Disruptor无锁缓存框架声明：原创文章，转载请注明出处。http://www.jianshu.com/u/e02df63eaa87 1、从生产者消费者说起 在传统的生产者消费者模型中，通常是采用Bl...
