# flink-cpu-demo

**Repository Path**: smile-yan/flink-cpu-demo

## Basic Information

- **Project Name**: flink-cpu-demo
- **Description**: flink 监听 CPU 使用率的案例
- **Primary Language**: Unknown
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2024-05-06
- **Last Updated**: 2024-05-12

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# flink-cpu-demo

一个简单的 flink stream API 案例，在本案例中，使用到 Stream API 包括：

* flink-kafka connector 序列化与反序列化
* flink window 窗口操作
* flink ProcessWindowFunction 窗口合并处理
* flink window 窗口触发器 Trigger 
* flink mapFunction 合并窗口后的风险评估操作
* flink 的 keyBy 操作，根据关键字合并消息

案例明细请参考我的个人博客：
https://blog.csdn.net/smileyan9/article/details/138507466

## 使用方法

### 环境依赖

请确保个人电脑已经安装好 jdk 1.8 并配置好环境变量。

### clone 到本地并使用 IDEA 打开

```bash
$ git clone git@gitee.com:smile-yan/flink-cpu-demo.git
```

可以考虑使用命令打开项目

```bash
$ idea open flink-cpu-demo
```

### 本地执行 main 方法即可

此处需要注意运行时 `add dependencies with provided scope in classpath`。

具体操作请参考
https://blog.csdn.net/smileyan9/article/details/134732120

## 致谢

多谢各位小伙伴们的支持 ~ 任何问题欢迎 ISSUE 或者到本人博客下留言。

感谢 ~