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;

eamocanu

{:timestamp=>"2015-09-03T11:04:18.391000-0400", :message=>"+---------------------------------------------------------+\n| An unexpected error occurred. This is probably a bug.   |\n| You can find help with this problem in a few places:    |\n|                                                         |\n| * chat: #logstash IRC channel on freenode irc.          |\n|     IRC via the web: http://goo.gl/TI4Ro                |\n| * email: logstash-users@googlegroups.com                |\n| * bug system: https://logstash.jira.com/                |\n|                                                         |\n+---------------------------------------------------------+\nThe error reported is: \n  Address already in use - bind - Address already in use"}
{:timestamp=>"2015-09-03T11:09:55.098000-0400", :message=>"Using milestone 1 input plugin 'lumberjack'. This plugin should work, but would benefit from use by folks like you. Please let us know if you find bugs or have suggestions on how to improve this plugin.  For more