七天爆肝flink笔记

我才是真的封不觉

于 2024-02-15 12:59:36 发布

阅读量830

点赞数 11

CC 4.0 BY-SA版权

文章标签： flink 笔记大数据

本文链接：https://blog.csdn.net/JavaCoder_juejue/article/details/136119744

一.flink整体介绍及wordcount案例代码

1.1整体介绍

从上到下包含有界无界流 支持状态 特点 与spark对比 应用场景架构分层

1.2示例代码

了解了后就整个demo吧

数据源准备这里直接用的文本文件

gradle中的主要配置

group = 'com.example'
version = '0.0.1-SNAPSHOT'

java {
    sourceCompatibility = '11'
}

repositories {
    mavenCentral()
}

dependencies {
    implementation group: 'org.apache.flink', name: 'flink-streaming-java', version: '1.17.0'
    implementation group: 'org.apache.flink', name: 'flink-clients', version: '1.17.0'

}

代