学习大数据-flink实时数据流处理
流处理：数据是实时得批处理数据是等待达到某一批后再处理数据。
·
Flink得应用场景
- IOT实时数据采集
- 金融、银行得风控管理
- 电商网站得实时数据报表
什么是流处理、批处理
流处理：数据是实时得
批处理数据是等待达到某一批后再处理数据
DataStream API 执行环境
创建执行环境----》获取对应数据源—》流过来的数据进行加工处理—》输出----》不断监听处理
挂起什么意思
一直等待任务过来，来了之后就执行。
转换算子
代码-gitee-转换算子
聚合算子
自定义ReduceFunction 做聚合逻辑处理
富合函数
输出
输入到mysql
Table Api入门案例编写
永洪科技，致力于打造全球领先的数据技术厂商，具备从数据应用方案咨询、BI、AIGC智能分析、数字孪生、数据资产、数据治理、数据实施的端到端大数据价值服务能力。
更多推荐
0
0- 0
已为社区贡献3条内容
所有评论(0)