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,并且键值也可能会重复、接下我把map都存入list
List<HashMap<Integer,Integer>> mylist
然后我用sparkcontext.parallelize方法怎么单词计数啊?
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,并且键值也可能会重复、接下我把map都存入list
List<HashMap<Integer,Integer>> mylist
然后我用sparkcontext.parallelize方法怎么单词计数啊?
不方便导出,直接截图看了~~Scala版本的,改为Java版本的工作量也不大。