eamocanu

import scala.collection.mutable

/**
 * Bounded priority queue trait that is intended to be mixed into instances of
 * scala.collection.mutable.PriorityQueue. By default PriorityQueue instances in
 * Scala are unbounded. This trait modifies the original PriorityQueue's
 * enqueue methods such that we only retain the top K elements.
 * The top K elements are defined by an implicit Ordering[A].
 * @author Ryan LeCompte (lecompte@gmail.com)
 */

eamocanu

import java.io.{IOException, ObjectOutputStream}

import scala.language.existentials
import scala.reflect.ClassTag

import org.apache.spark._
import org.apache.spark.rdd.RDD


case class GroupedRDDPartition(

eamocanu

.twitter-typeahead .tt-hint {
  border: 0;
  padding: 0;
}

.tt-dropdown-menu {
  min-width: 160px;
  margin-top: 2px;
  padding: 5px 0;
  background-color: #fff;