Flink 概述 Flink

Flink 概述

基本功能 Apache Flink是一个面向分布式数据流处理和批量数据处理的开源计算平台,它能够基于同一个Flink运行时,提供支持流处理和批处理两种类型应用的功能。 现有的开源计算方案,会把流处理和批处理作为两种不同的应用类型,因为它们所提供的SLA(Ser...
阅读全文
Flink 容错机制 Flink

Flink 容错机制

这里把各种资料里认为和容错有关的概念放在一起来解释,这样或许能更好的理解Flink强大的容错机制。主要的概念有四个:Stage、Checkpoint、SavePoint、Barrier。 Flink容错 Apache Flink 提供了可以恢复数据流应用到一致...
阅读全文
Apache Calcite — 入门介绍 Calcite

Apache Calcite — 入门介绍

一、功能概述 Calcite是Apache孵化的一个项目,主要作用是提供标准的SQL语言查询底层各种数据源的一个工具,注意它不是个服务,一般常用作集成到某些框架里,比如Apache Drill、Apache Hive、Apache Kylin、Apache P...
阅读全文
2019年,这一年我跑了1290公里 生活随笔

2019年,这一年我跑了1290公里

一月已悄然过半,人总是能给自己找很多借口,拖到现在才动手写这篇文章,回顾下2019年的运动记录。 发现一个有意思的现象,一旦开始以“年”为单位计划某些事情,时间会过的更快。又一个春夏秋冬,2019是坚持运动的第二年,对于我这个程序员来说,还算坚持的不错,至少唯...
阅读全文
2018年,这一年我跑了1100公里 生活随笔

2018年,这一年我跑了1100公里

跑步,是一件很容易也很难做到的事情。说容易,是因为它相对其他运动形式,对参与者、设备器械等都没有太高要求,穿上鞋跑就好了。但说它难,是因为不管是出于减肥、坚持、锻炼各种各样的目的,立下多么狠的flag,最终还是有大部分人放弃,因为它确实太枯燥了。2018,我用...
阅读全文