# flink-demo

**Repository Path**: hi_zhangziyi/flink-demo

## Basic Information

- **Project Name**: flink-demo
- **Description**: flink demo
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 2
- **Created**: 2024-12-24
- **Last Updated**: 2024-12-24

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# flink-demo

## 官方仓库
* [apache官方仓库](https://repository.apache.org/content/repositories/)
* [flink仓库](https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-kafka/)

## 代码结构
```text
flink-demo
├─conf                          配置文件
├─hive.conf                     hive配置文件
├─profile.d                     环境配置
├─src/main
│      ├─java/com/at            测试代码
│      │          ├─wc1             word count示例
│      │          ├─env2            环境示例
│      │          ├─bean            实体类：水位传感器
│      │          ├─source3         数据源示例：集合、文件、kafka、DataGen
│      │          ├─transform4      转换算子：map、filter、flatmap、富函数
│      │          ├─functions5      自定义函数：Map、Filter
│      │          ├─aggregate6      聚合算子：keyby、reduce、aggregate
│      │          ├─partition7      分区器
│      │          ├─split8          分流、侧输出流
│      │          ├─combine9        合并：union、connect
│      │          ├─sink10          输出：文件、kafka、mysql、自定义
│      │          ├─window11        窗口：滑动、滚动、会话、reduce、aggregate、process、时间窗口、计数窗口
│      │          ├─watermark12     水位线：升序、乱序、自定义、空闲等待、允许迟到、窗口join、间隔join
│      │          │  └─generator        水位线生成器
│      │          ├─process13       处理函数：定时器、TopN、侧输出流告警
│      │          ├─state14         状态：单值、List、Map、Reducing、Aggregating、操作List（数据恢复）、数据流+配置流（广播）connect
│      │          ├─checkpoint15    检查点：检查点配置、保存点、Kafka精准一次
│      │          └─sql16           代码中调用sql：基本用法、Table API、表值函数、表函数、聚合函数、表聚合函数
│      └─resources
├─doc
├─input                         测试数据
└─sql                           flink-sql
   ├─1-语法                          部分语法
   ├─2-demo                         demo：DataGen、简单查询、分组聚合&多维分析、窗口聚合TVF、over聚合、TopN、Deduplicate去重、Join-常规、间隔、维表、order by、集合操作、系统函数、Module操作
   ├─3-连接器                        kafka、file、mysql
   └─5-Catalog                      Catalog: Jdbc、Hive
```