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
++= 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
++= 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
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
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
)(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