Flink算法实现练习(2)
发布时间
阅读量:
阅读量
Map
随机生成班级学生的学业评估数据
- 输入参数:本班全体学生的编号信息
- 输出结果:<学生编号,对应学业成绩>
数据准备
1.【1.
首要条件是准备一个名为stuID.csv的文件,其中每一列对应一个学生的学号:
*

接下来,把该文件存储至HDFS系统中:
hdfs dfs put stuID.csv input
编写程序
import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink
全部评论 (0)
还没有任何评论哟~
