Re: Implementing top() using treeReduce()

2015-06-17 Thread DB Tsai
is that I cannot use these 2 lines of code which are used in the top() action within my Spark application. val queue = new BoundedPriorityQueue[T](num)(ord.reverse) queue ++= util.collection.Utils.takeOrdered(items, num)(ord) How can I go about implementing top() using treeReduce

Re: Implementing top() using treeReduce()

2015-06-17 Thread Raghav Shankar
++= util.collection.Utils.takeOrdered(items, num)(ord) How can I go about implementing top() using treeReduce()? -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Implementing-top-using-treeReduce-tp23227.html http://apache-spark-user-list.1001560.n3

Re: Implementing top() using treeReduce()

2015-06-17 Thread DB Tsai
++= util.collection.Utils.takeOrdered(items, num)(ord) How can I go about implementing top() using treeReduce()? -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Implementing-top-using-treeReduce-tp23227.html Sent from the Apache Spark User List mailing list archive

Re: Implementing top() using treeReduce()

2015-06-17 Thread Raghav Shankar
application. val queue = new BoundedPriorityQueue[T](num)(ord.reverse) queue ++= util.collection.Utils.takeOrdered(items, num)(ord) How can I go about implementing top() using treeReduce()? -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Implementing

Implementing top() using treeReduce()

2015-06-09 Thread raggy
of code which are used in the top() action within my Spark application. val queue = new BoundedPriorityQueue[T](num)(ord.reverse) queue ++= util.collection.Utils.takeOrdered(items, num)(ord) How can I go about implementing top() using treeReduce()? -- View this message in context: http://apache

Re: Implementing top() using treeReduce()

2015-06-09 Thread DB Tsai
)(ord) How can I go about implementing top() using treeReduce()? -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Implementing-top-using-treeReduce-tp23227.html Sent from the Apache Spark User List mailing list archive at Nabble.com