HashMap<Integer,Integer> map1 = new HashMap<>();
map1.put(1,100);
map1.put(2,150);
map1.put(3,120);
HashMap<Integer,Integer> map2 = new HashMap<>();
map2.put(2,200);
map2.put(7,20);
map2.put(3,66);
//可能還有很多map,數量不確定,并且鍵值也可能會重復
List<HashMap<Integer,Integer>> mylist = new ArrayList<>();
然后現在我拿到sc物件,想要做個單詞計數測驗
JavaRDD<String> lines = sc.parallelize(mylist);
結果no instance(s) of type variable(s) T exist so that List<T> conforms to Seq<T>
想問一下該怎么初始化這個資料?
uj5u.com熱心網友回復:
sc.parallelize 要求引數為Seq型別,你把ArrayList 替換為Seq的繼承類試試uj5u.com熱心網友回復:
我專案里只引入了spark core的依賴,和這個有關系么uj5u.com熱心網友回復:
就看你執行的時候,會不會報錯提示類缺失等等,有的話就找到相應的jar報添加就可以了uj5u.com熱心網友回復:
hashmap 物件需要序列化uj5u.com熱心網友回復:

不方便匯出,直接截圖看了~~Scala版本的,改為Java版本的作業量也不大。居然發了兩次。
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/42591.html
標籤:Spark
