一、flink介绍 Apache Flink是一个分布式大数据处理引擎，可对 有界数据流和 无界数据流进行 有状态计算。 可部署在各种集群环境，对各种大小的数据规模进行快速计算。 1.1、有界数据流和无界数据流 1、 无界流有一个开始但没有定义的结束。它们不会在 ...

1. Flink简介 Apache Flink是一个面向分布式数据流处理和批量数据处理的开源计算平台，它能够基于同一个Flink流执行引擎（streaming dataflow engine），提供支持流处理和批处理两种类型应用的功能。batch dataSet可以视作data ...

一、Grain持久性 二、定时器和提醒 三、依赖注入 四、观察者 五、无状态工作者Grains 六、流 一、Grain持久化 1，Grain持久化目标 ①允许不同类型的存储提供者使用 ...

统一接口设计风格： 1.URL地址尽量使用名词，不要出现动词 2.使用不同的请求方式，代表要执行不同的操作 (GET)获取 POST(新增) PUT（修改）DELETE（删除） 不常用：PATCH ...

公司主要做的事物联网和数字孪生，下半年我们项目要接入大数据，要进行处理再整合Drools，进行规则预警。最近几个月一直在忙pmp考试和平时工作，也没有进行学习整理，最近就开始学习flink和kafka，记点笔记。 Flink组件栈 一个计算框架要有长远的发展，必须打造一个完整的 Stack ...

聊聊spring spring对于java开发者来说，是最熟悉不过的框架了，我们日常开发中每天都在使用它。它有着各种各样的好处，简单易用，得心应手... ... 我们一说到sp ...

前言 Flink 是一种流式计算框架，为什么我会接触到 Flink 呢？因为我目前在负责的是监控平台的告警部分，负责采集到的监控数据会直接往 kafka 里塞，然后告警这边需要从 kafka topic 里面实时读取到监控数据，并将读取到的监控数据做一些 聚合/转换/计算 等操作 ...

1、理解 State（状态） 1.1、State 对象的状态 Flink 中的状态：一般指一个具体的 task/operator 某时刻在内存中的状态（例如某属性的值）。 注意：State 和 Checkpointing 不要搞混。 checkpoint ...