发简信
IP属地：浙江
-
flink的Snapshot
flink的snapshot的算法在这篇论文，本文讲述也是基于这部分内容，如果有兴趣可以自行参考原文。 介绍 目前已知的能够保证只执行一次...
-
flink的内存管理在大数据面前，JVM的内存结构和GC机制往往会成为掣肘 1. 对象开销：在HotSpot中，每个对象占用的内存空间必须是8的倍数。这就导致每个对...
-
flink-example
在我的git，:) -_-||
-
flink的执行计划——StreamGraph
flink的执行计划分为四层： 通过Stream API提交的文件，首先会被翻译成StreamGraph。StreamGraph的生成的逻辑是在...
-
flink client/JobManager/TaskManager的启动这里只介绍Standalone模式 Client flink官方支持多种模式standalone/yarn/mesos flink在启动的时候，...
-
[zz]Functor, Applicative, 以及 Monad 的图片阐释这是个简单的值: 我们都知道怎么加一个函数应用到这个值上边: 很简单了. 我们来扩展一下, 让任意的值是在一个上下文当中. 现在的情况你可以想象...
-
Storm Nimbus的HAStorm在1.0之后对nimbus支持了HA，根据官方提供的文档，同样是利用了zk来做分布式锁，并且配置文件中新增了storm.seeds，而...
-
Storm LinearDrpc以ReachTopology为例子，这个类在storm-starter里。 LinearDRPC顾名思义是线性的，bolt的处理流程是linea...