# hflink1.12

**Repository Path**: hanrentong/hflink1.12

## Basic Information

- **Project Name**: hflink1.12
- **Description**: flink1.12版本java
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 1
- **Forks**: 1
- **Created**: 2021-05-03
- **Last Updated**: 2022-03-01

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

flink1.12版本学习
1.12版本真正实现了批流一体,DatasetApi已经被软弃用了(虽然能使用,但是已经过期)。

com.hrt.flink.action.DoubleElevenBigScreem 双十一大屏需求
    1.实时计算出当天零点截止到当前时间的销售总额 11月11日 00:00:00 ~ 23:59:59(怎么取到0点到当前的时间,也很牛逼,不是简单的滑动和滚动)
    2.计算出各个分类的销售top3(小顶堆排序很牛逼,求top的方法可以借鉴)
    3.每秒钟更新一次统计结果
com.hrt.flink.action.OrderAutomaticFavorableComments  订单自动好评的需求(很牛逼,用到了定时器设置超时以及状态管理)
com.hrt.flink.feature.BroadcastState1
     两个流的关联案例: 一个是数据流,一个是维度流,然后进行关联,由于维度流数据流小所以用broadcast,这里面可能会有关联不上的情况需要考虑(如果关联不上,就下一次关联了)。
                    毕竟两个流不可能实时同步
com.hrt.flink.feature包下的东西都很重要(高级特性)