Flink 批计算单词统计示例

概述

在流计算实现单词统计的基础上，Flink 同样支持批计算功能。本文将演示如何通过批计算模式实现单词统计。

环境准备

Maven 依赖配置略过，核心逻辑如下。

源数据

输入文本数据示例：

text
aaa bbb ccc
bbb ddd ee
ccc fff fff gggg
hhh a h gg

Java 实现

package com.hy.flinktest;

import org.apache.commons.lang3.StringUtils;
import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.operators.AggregateOperator;
import org.apache.flink.api.java.operators.DataSource;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.core.fs.FileSystem;
import org.apache.flink.util.Collector;

/**
 * ClassName: BatchWordCountJava
 * Description:
 */