栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

【Flink】小例子入门

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

【Flink】小例子入门

Flink

介绍

基于数据流的,有状态的计算,计算作用在有界或者无界的数据流上

流类型

无界流:有开始,没有结束的数据流,采用的处理方式按照一定顺序处理(时间。。。)

有界流:有开始,有结束的数据流,经常采用处理方式用批处理

spark、flink对比

1、spark、flink 支持流、批处理

2、flink 高吞吐、低延迟

词频统计

需求:词频统计(word count),一个文件,统计文件中每个单词出现的次数,分隔符是t,统计结果输出到控制台(生产环境上肯定是Sink到达目的地)

开发批处理应用程序

实现方式

flink+Java

Apache Flink 1.7 documentation: Project Template for Java

开发流程/开发八股文编程

  1. set up the batch execution environment(设置批处理执行环境)
  2. read(读取数据)
  1. tranform operations(开发的核心所在:开发业务逻辑)
  2. execute program

flink+scala

Apache Flink 1.7 documentation: Project Template for Scala

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/749077.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号