基于Flink的批流处理API编程实现wordcount案例_flink http api运行批处理-CSDN博客

网站介绍:文章浏览阅读180次。1: 基于DataSet 批处理的API编程(最新版本Flink 1.12.0已经淘汰)import org.apache.flink.api.common.functions.FlatMapFunction;import org.apache.flink.api.common.functions.MapFunction;import org.apache.flink.api.java.ExecutionEnvironment;import org.apache.flink.api.java.ope_flink http api运行批处理