1、TopN的排序 Scala开发 读入数据 1 4 2 5 7 9 11 23 1 2 5 6 7 8
topn排序结果 23 11 9 8 7
按隐士转换,按字符串排序运行结果 9 8 7 7 6
2、TOPN分组排序,使用JAVA开发 输入文件 Spark 100 Hadoop 62 Flink 77 Kafka 91 Hadoop 93 Spark 78 Hadoop 69 Spark 98 Hadoop 62 Spark 99 Hadoop 61 Spark 70 Hadoop 75 Spark 88 Hadoop 68 Spark 90 Hadoop 61
运行结果 Group key :Flink 77 null null null null ********************** Group key :Spark 100 99 98 90 88 ********************** Group key :Kafka 91 null null null null ********************** Group key :Hadoop 93 75 69 68 62