"/data.txt",32);
>>>> //parallelize(l,
>>>> 8);
>>>> long start = System.currentTimeMillis();
>>>> JavaRDD>> rdd3 =
>>>> rdd.mapPartitions(new FlatMapFunction,
>>>> LinkedList>>
vaRDD>> rdd3 =
>>> rdd.mapPartitions(new FlatMapFunction,
>>> LinkedList>>(){
>>>
>>> @Override
>>> public Iterable>>
>>> call(Iterator t)
>>> throws
erride
>> public Iterable>>
>> call(Iterator t)
>> throws Exception {
>> // TODO Auto-generated method stub
>> LinkedList> lines = new
>> LinkedList>();
>> while(t.hasNext()){
>>
List>();
> while(t.hasNext()){
> String s = t.next();
> String arr1[] = s.split(",");
> Tuple2 t1 = new Tuple2 String>(Double.parseDouble(arr1[24]),s);
> lines.add(t1);
> }
> Colle
}
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Different-Sorting-RDD-methods-in-Apache-Spark-tp23214.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
-
To
