Flink 从集合中获取数据,我们直接看代码: 输出结果:
分类: 框架
Flink从入门到实战四[DataStream API]-4-Source数据源
Flink应用要计算,必须要有执行环境,有了执行环境,那么就需要将要数据输入到计算应用中了。Flink提供了丰… 继续阅读 Flink从入门到实战四[DataStream API]-4-Source数据源
Flink从入门到实战四[DataStream API]-3-3_StreamExecutionEnvironment API解析
StreamExecutionEnvironment内部的方法非常多,我们从整体功能上进行简单划分,主要包括:… 继续阅读 Flink从入门到实战四[DataStream API]-3-3_StreamExecutionEnvironment API解析
Flink从入门到实战四[DataStream API]-2-Environment运行时环境
Environment 是所有 Flink 程序的基础,每个 Flink 应用都需要有执行环境,Flink1.… 继续阅读 Flink从入门到实战四[DataStream API]-2-Environment运行时环境
Flink从入门到实战四[DataStream API]-1-DataStream API简介
DataStream API是Flink用于数据处理的API。是对有界数据和无界数据处理的API。 DataS… 继续阅读 Flink从入门到实战四[DataStream API]-1-DataStream API简介
Flink从入门到实战三[架构]-1_Flink运行时架构
Flink 运行时由两种类型的进程组成:一个 JobManager 和一个或者多个 TaskManager。 … 继续阅读 Flink从入门到实战三[架构]-1_Flink运行时架构
Flink从入门到实战二[部署]-1-Flink Standalone集群部署
前面章节已经过单机Standalone模式,接下来我们看一下Standalone的集群模式部署。我们以官网部署… 继续阅读 Flink从入门到实战二[部署]-1-Flink Standalone集群部署
Flink从入门到实战一[快速上手]-8-Flink官方反欺诈项目版本3
官方网站使用了一个欺诈检测的项目来演示Flink的功能特性,但是这个项目对于之前完全没有接触过大数据计算框架的… 继续阅读 Flink从入门到实战一[快速上手]-8-Flink官方反欺诈项目版本3
Flink从入门到实战一[快速上手]-7-Flink官方反欺诈项目版本2
官方网站使用了一个欺诈检测的项目来演示Flink的功能特性,但是这个项目对于之前完全没有接触过大数据计算框架的… 继续阅读 Flink从入门到实战一[快速上手]-7-Flink官方反欺诈项目版本2
Flink实战学习1[快速上手]-6-Flink官方反欺诈项目版本1
官方网站使用了一个欺诈检测的项目来演示Flink的功能特性,但是这个项目对于之前完全没有接触过大数据计算框架的… 继续阅读 Flink实战学习1[快速上手]-6-Flink官方反欺诈项目版本1
Flink从入门到实战一[快速上手]-5-Flink HelloWorld之流处理WordCount-Socket
flink中的数据分为有界流数据和无界流数据,对应的处理计算叫做批处理和流处理,批处理对应的API是DataS… 继续阅读 Flink从入门到实战一[快速上手]-5-Flink HelloWorld之流处理WordCount-Socket
Flink从入门到实战一[快速上手]-4-Flink HelloWorld之流处理WordCount
flink中的数据分为有界流数据和无界流数据,对应的处理计算叫做批处理和流处理,批处理对应的API是DataS… 继续阅读 Flink从入门到实战一[快速上手]-4-Flink HelloWorld之流处理WordCount
Flink从入门到实战一[快速上手]-3-Flink HelloWorld之批处理WordCount
flink中的数据分为有界流数据和无界流数据,对应的处理计算叫做批处理和流处理,批处理对应的API是DataS… 继续阅读 Flink从入门到实战一[快速上手]-3-Flink HelloWorld之批处理WordCount
Flink从入门到实战一[快速上手]-2-Flink本地模式安装
运行Flink的前提,需提前安装好 Java 8 或者 Java 11。 1:下载并解压下载地址:https:… 继续阅读 Flink从入门到实战一[快速上手]-2-Flink本地模式安装
Flink 1.14.3从入门到实战一[快速上手]-1-Apache Flink是什么
Apache Flink 是什么?我们来看一下官方的解释。Apache Flink 是一个框架和分布式处理引擎… 继续阅读 Flink 1.14.3从入门到实战一[快速上手]-1-Apache Flink是什么
Git常用命令
常用命令 文件操作 分支操作 Tag 撤销/恢复
git提交问题:码云remote: error: File: , exceeds 100.00 MB
使用码云作为代码版本库,提交文件是报错:remote: error: File: , exceeds 100.… 继续阅读 git提交问题:码云remote: error: File: , exceeds 100.00 MB
Mybatis-plus分页插件配合导致distinct无效
首先说一下问题场景:在使用mybatis-plus进行分页,分页数据是一个一对多的查询结果集,并且,结果集的s… 继续阅读 Mybatis-plus分页插件配合导致distinct无效
git clone 报错fatal: unable to access,URL using bad/illegal format or missing URL
git clone项目,提示报错如下: 首先确定账号密码是正确的 账密正确,那么还报错,只有一个原因了:因为用… 继续阅读 git clone 报错fatal: unable to access,URL using bad/illegal format or missing URL
Mybatis执行报错 Error querying database. Cause: com.microsoft.sqlserver.jdbc.SQLServerException: “,”附近有语法错误
Mybatis执行报错: Error querying database. Cause: com.micros… 继续阅读 Mybatis执行报错 Error querying database. Cause: com.microsoft.sqlserver.jdbc.SQLServerException: “,”附近有语法错误