Flink的重启策略 Flink支持不同的重启策略，这些重启策略控制着job失败后如何重启。集群可以通过默认的重启策略来重启，这个默认的重启策略通常在未指定重启策略的情况下使...
发简信
IP属地：山西
-
Flink的重启策略
-
Flink 有状态的流的工作(Working with state)
有状态的函数和操作在处理各个元素或者事件时存储数据，使得state称为任何类型的复杂操作的关键构建部件,例如:当一个应用程序搜索某些特定的事件模式时，状态会保存截止到目前为止...
-
Flink 的Window 操作
Flink的 Window 操作 Window是无限数据流处理的核心，Window将一个无限的stream拆分成有限大小的”buckets”桶，我们可以在这些桶上做计算操作。...
-
深入理解Flink中的状态实现
本文是整理自几个月前的内部flink state分享，flink状态所包含的东西很多，在下面列举了一些，还有一些在本文没有体现，后续会单独的挑出来再进行讲解 state的层次...
-
Java高级特性——反射
概述 定义 JAVA反射机制是在运行状态中，对于任意一个类，都能够知道这个类的所有属性和方法；对于任意一个对象，都能够调用它的任意方法和属性；这种动态获取信息以及动态调用对象...
-
flink学习之七-map、fliter、flatmap
看完了Flink的datasource、sink，也就把一头一尾给看完了，从数据流入到数据流出，缺少了中间的处理环节。 而flink的大头恰恰是只在这个中间环节，如下图： 中...
-
python logging模块使用教程本文章是我大概三年前，在上家单位使用 Python 工作时结合官方文档做的整理。现在 Python 官方文档听说已经有了中文版，所以大家可以直接去官网看文档，本篇文章仍旧放在...
-
Grafana全面瓦解1.概述--美观、强大的可视化监控指标展示工具 grafana 是一款采用 go 语言编写的开源应用，主要用于大规模指标数据的可视化展现，是网络架构和应用分析中最流行的时序数...
-
Java中Iterable和Iterator接口
接口定义 Iterable只是返回了Iterator接口的一个实例，这里很是奇怪，为什么不把两个接口合二为一，直接在Iterable里面定义hasNext(),next()等...
