spark 學習記錄 二次Key排序的使用方法

目的是爲了當key相同的時候,對value進行自定義排序spa //二次排序,具體實現步驟排序 //第一步:按照Ordered和Serrializable接口實現自定義排序的Key接口 按照須要排序的字段重寫ordered的方法it //第二步:將要進行二次排序的文件加載進來生成《key,value》類型的RDD方法 將pairRDD轉換成二次排序的bean,將原來的反轉一次Maptopair("
相關文章
相關標籤/搜索