org.apache.spark.util

Class BoundedPriorityQueue<A>

Object

org.apache.spark.util.BoundedPriorityQueue<A>

All Implemented Interfaces:

java.io.Serializable, scala.collection.generic.Clearable, scala.collection.generic.FilterMonadic<A,scala.collection.Iterable<A>>, scala.collection.generic.GenericTraversableTemplate<A,scala.collection.Iterable>, scala.collection.generic.Growable<A>, scala.collection.generic.HasNewBuilder<A,scala.collection.Iterable<A>>, scala.collection.GenIterable<A>, scala.collection.GenIterableLike<A,scala.collection.Iterable<A>>, scala.collection.GenTraversable<A>, scala.collection.GenTraversableLike<A,scala.collection.Iterable<A>>, scala.collection.GenTraversableOnce<A>, scala.collection.Iterable<A>, scala.collection.IterableLike<A,scala.collection.Iterable<A>>, scala.collection.Parallelizable<A,scala.collection.parallel.ParIterable<A>>, scala.collection.Traversable<A>, scala.collection.TraversableLike<A,scala.collection.Iterable<A>>, scala.collection.TraversableOnce<A>, scala.Equals

public class BoundedPriorityQueue<A>
extends Object
implements scala.collection.Iterable<A>, scala.collection.generic.Growable<A>, java.io.Serializable

Bounded priority queue. This class wraps the original PriorityQueue class and modifies it such that only the top K elements are retained. The top K elements are defined by an implicit Ordering[A].

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface scala.collection.TraversableLike

scala.collection.TraversableLike.WithFilter

Constructor Summary

Constructors

Constructor and Description
BoundedPriorityQueue(int maxSize, scala.math.Ordering<A> ord)

Method Summary

Methods

Modifier and Type	Method and Description
void	clear()
scala.collection.Iterator<A>	iterator()
int	size()

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.collection.Iterable

companion, seq

Methods inherited from interface scala.collection.IterableLike

canEqual, copyToArray, drop, dropRight, exists, find, foldRight, forall, foreach, grouped, head, isEmpty, reduceRight, sameElements, slice, sliding, sliding, take, takeRight, takeWhile, thisCollection, toCollection, toIterable, toIterator, toStream, view, view, zip, zipAll, zipWithIndex

Methods inherited from interface scala.Equals

equals

Methods inherited from interface scala.collection.TraversableLike

$plus$plus, $plus$plus$colon, $plus$plus$colon, collect, dropWhile, filter, filterNot, flatMap, groupBy, hasDefiniteSize, headOption, init, inits, isTraversableAgain, last, lastOption, map, parCombiner, partition, repr, scan, scanLeft, scanRight, sliceWithKnownBound, sliceWithKnownDelta, span, splitAt, stringPrefix, tail, tails, to, toString, toTraversable, withFilter

Methods inherited from interface scala.collection.GenTraversableOnce

$div$colon$bslash

Methods inherited from interface scala.collection.generic.Growable

$plus$eq, $plus$eq, $plus$plus$eq

Constructor Detail

BoundedPriorityQueue

public BoundedPriorityQueue(int maxSize,
                    scala.math.Ordering<A> ord)

Method Detail

iterator

public scala.collection.Iterator<A> iterator()

Specified by:

iterator in interface scala.collection.GenIterableLike<A,scala.collection.Iterable<A>>

Specified by:

iterator in interface scala.collection.IterableLike<A,scala.collection.Iterable<A>>

size

public int size()

Specified by:

size in interface scala.collection.GenTraversableLike<A,scala.collection.Iterable<A>>

Specified by:

size in interface scala.collection.GenTraversableOnce<A>

Specified by:

size in interface scala.collection.TraversableOnce<A>

clear

public void clear()

Specified by:

clear in interface scala.collection.generic.Clearable

Specified by:

clear in interface scala.collection.generic.Growable<A>