# flink

**Repository Path**: cch-bigdata/flink

## Basic Information

- **Project Name**: flink
- **Description**: flink作业
- **Primary Language**: Scala
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2021-10-07
- **Last Updated**: 2021-10-12

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# flink

#### 介绍
flink作业

#### 类文件说明

##### 任务一:idea代码编写入门案例
- 入门案例(批):src/main/scala/com/cch/demo/bigdata/flink/helloworld/batch/WordCountDemo.scala
- 入门案例(流):src/main/scala/com/cch/demo/bigdata/flink/helloworld/stream/WordCountDemo.scala

##### 任务二:window机制案例代码
- 基于事件的滚动窗口:src/main/scala/com/cch/demo/bigdata/flink/window/roll/RollWindowDemoByEvent.scala
- 基于时间的滚动窗口:src/main/scala/com/cch/demo/bigdata/flink/window/roll/RollWindowDemoByTime$.scala

- 滑动时间窗口:src/main/java/com/cch/demo/bigdata/flink/window/sliding/SlidingWindowDemo.java
- 会话窗口:src/main/java/com/cch/demo/bigdata/flink/window/session/SessionWindowDemo.java

##### 任务三 watermark案例代码编写,state案例代码编写
- watermark代码:src/main/java/com/cch/demo/bigdata/flink/watermark/WaterMarkDemo.java
- state代码:src/main/java/com/cch/demo/bigdata/flink/state/StateDemo.java

##### 任务四 并行度设置
- src/main/java/com/cch/demo/bigdata/flink/parallelism/ParallelismDemo.java


##### 任务五 flink table案例
- src/main/java/com/cch/demo/bigdata/flink/table/TableDemo.java