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()等...
-
Flink Table API 和 SQL
Apache Flink 具有两个关系型API：Table API 和SQL，用于统一流和批处理。Table API 是用于 Scala 和 Java 语言的查询API，允许...
-
源码理解Spring中的各种context前言：最近看dispatcherServlet的源码分析，被各种context搞得想骂X，但抱怨过后还得看呀，于是开始各种搜索，总结性的工作又要开始了。看本篇之前建议先看看：...
-
flink学习之八-keyby&reduce
上文学习了简单的map、flatmap、filter，在这里开始继续看keyBy及reduce keyBy 先看定义，通过keyBy，DataStream→KeyedStre...
-
Flink Checkpoint
Flink中的每个函数和算子都可以是有状态的(详情请看Working With State),有状态的函数通过处理各个元素或者事件来存储数据，使得State称为任何更复杂的操...
-
HBase配置文件详解（一）
HBase使用与Hadoop相同的配置系统，所有配置文件都位于 conf/ 目录中，需要保持群集中每个节点的同步。 配置文件说明 backup-masters - 这是一个纯...
-
什么是分布式锁学习完整课程请移步 互联网 Java 全栈工程师 本节视频 【视频】Dubbo 实现微服务架构-Zookeeper-什么是分布式锁1 【视频】Dubbo 实现微服务架构-Zo...
-
Python collection模块
最近看到这篇文章，collection模块写的最详细了，所以想分享给大家 Python中的基本数据结构有list，dict，tuple，set。Python还有一个功能比较强...
-
python中defaultdict用法详解
认识defaultdict： 当我使用普通的字典时，用法一般是dict={},添加元素的只需要dict[element] =value即，调用的时候也是如此，dict[ele...
-
操作系统进程的状态转换
一，三态模型 一个进程从创建而产生至撤销而消亡的整个生命周期，可以用一组状态加以刻划，根据三态模型，进程的生命周期可分为如下三种进程状态： 1. 运行态(running):占...
-
python中文（汉字）转拼音
1.python库pypinyin 可以使用 pip 进行安装: $ pip install pypinyin easy_install 安装: $ easy_install...
