Advertisement

Flink算法实现练习(2)

阅读量:

Map

随机生成班级学生的学业评估数据

  • 输入参数:本班全体学生的编号信息
  • 输出结果:<学生编号,对应学业成绩>

数据准备

1.【1.

首要条件是准备一个名为stuID.csv的文件,其中每一列对应一个学生的学号:

复制代码
 *
53991837251

接下来,把该文件存储至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)

还没有任何评论哟~