国外优秀电商网站友链网站

本文重点

本文将通过一个统计词频的小程序来看一下flink是如何对数据进行批处理的，需要声明的是，一般我们使用Flink常常用于流式处理，即使是有界的数据，我们也将其看成是无界数据进行流式处理，所以批量处理并不是很常用，这里只是为了了解一下Flink是如何进行批处理的。

第一步创建一个flink的maven项目

引入jar包

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>org.example<