今天阳光很暖
Java service wrapper的使用与介绍 Java service wrapper的使用与介绍
1. 介绍Java Service Wrapper 是为了解决 Java 应用程序在部署和维护时的诸多问题而诞生的。它主要有以下几个功能： 将Java应用程序作为守护程序运行： Wrapper可以将Java应用程序作为Windows Se
2020-12-01 java
java
Flink CEP 的使用场景与示例 Flink CEP 的使用场景与示例
1. 检测登录用户的 IP 变化 使用场景 在我们操作某些银行APP的时候，经常会发现，如果上一个操作与下一个操作IP变换了例如上一个操作使用的流量操作，下一个操作我连接上了wifi去操作，这时IP就会发生变化，那么APP就要求我们重新进行
2020-11-07 flink
flink
Flink系列 17. 复杂事件处理 CEP Flink系列 17. 复杂事件处理 CEP
1. CEP 是什么 CEP 是 Complex Event Processing 三个单词的缩写，表示复杂事件处理。 CEP 是 Flink 专门为我们提供的一个基于复杂事件监测处理的库。 CEP 通过一个或多个由简单事件构成的事件流
2020-10-15 flink
flink
Flink系列 16. 介绍Flink中状态一致性的保证 Flink系列 16. 介绍Flink中状态一致性的保证
1. 一致性1.1 介绍状态一致性 有状态的流处理，内部每个算子任务都可以有自己的状态 对于流处理器内部来说，所谓的状态一致性，其实就是我们所说的要保证计算结果准确，一条数据有也不丢失，也不会重复计算数据 在程序遇到故障时可以恢复任务状态，
2020-10-13 flink
flink
Flink系列 15. 介绍Flink中Checkpoint与Savepoint Flink系列 15. 介绍Flink中Checkpoint与Savepoint
1. Flink Checkpoint1.1 Checkpoint 介绍 Flink Checkpoint 是容错恢复机制的核心。这种机制保证了保证实时程序运行时的数据安全，即使突然遇到异常也能够进行自我恢复。 Flink Checkpoi
2020-10-03 flink
flink
Flink系列 14. 介绍Flink中的StateBackend Flink系列 14. 介绍Flink中的StateBackend
1. 状态后端介绍 Flink 实时计算数据场景下，有时需要启动 checkpoint 保存数据的状态，那么状态会随着 checkpoint 被持久化某个地方，以防止数据丢失，保证状态数据能够在需要恢复程序状态时保持数据的一致性。而进行 c
2020-09-12 flink
flink
Flink系列 13. 介绍Flink中的Operator State 和 Keyed State Flink系列 13. 介绍Flink中的Operator State 和 Keyed State
1. Flink State 介绍1.1 什么是 State（状态） 由一个任务维护，并且用来计算某个结果的所有数据，就属于这个任务的状态 可以认为状态就是一个本地变量，可以被任务的业务逻辑访问 当任务失败时，可以使用状态恢复数据 状态始终
2020-09-06 flink
flink
Flink系列 12. 介绍Flink中 Timer 的使用 Flink系列 12. 介绍Flink中 Timer 的使用
1. Timer 介绍 Timer（定时器）是 Flink 提供的用于 Processing Time 或 Event Time 变化的机制。 Timer 是 Flink 内部的定时器，与 key 和 timestamp 相关，相同的 k
2020-08-29 flink
flink
Flink系列 11. 介绍Flink中 ProcessFunction 的使用 Flink系列 11. 介绍Flink中 ProcessFunction 的使用
1. ProcessFunction 介绍1.1 介绍Flink一般的转换算子是无法访问事件的时间戳信息和WaterMark信息的。例如 MapFunction 这样的 map 转换算子就无法访问时间戳或者当前事件的事件时间。而这在某些应用
2020-08-25 flink
flink
java.lang.NumberFormatException Not a version 9 异常处理 java.lang.NumberFormatException Not a version 9 异常处理
1. 异常说明今天写了一段 Flink 窗口 function 的代码运行的时候抛出一个 NumberFormatException: Not a version: 9 的异常，异常信息如下： 1234567891011121314151
2020-08-25 flink
exception flink
Flink系列 10. 介绍 Flink window function 的使用 Flink系列 10. 介绍 Flink window function 的使用
1. 窗口函数（window function）介绍定义完窗口分配器（WindowAssigner）之后，我们就需要指定要在每个窗口上执行的计算。这是Window Fucntion的职责，一旦系统确定窗口已准备好进行处理，就可以处理每个窗口
2020-08-05 flink
flink
hexo博客中增加知识图谱页 hexo博客中增加知识图谱页
1. 增加页面新建知识图谱页面 1hexo new page "graph" 执行完成之后在source 下面会增加 graph 文件夹以及文件夹中增加一个 index.md 文件 2. 配置菜单在 主题下面的_config.yml 文件中
2020-07-31 others
hexo
7 / 24