chobeat

class JPMMLEvaluationMapOperator(pmmlSource: String,
  inputPreparationErrorHandlingStrategy: InputPreparationErrorHandlingStrategy,

  missingValueStrategy: MissingValueStrategy,
  resultExtractionStrategy: ResultExtractionStrategy)
    extends RichMapFunction[Map[String, Any], Map[String, Serializable]] {

  //The evaluator is transient and built in the open() function to allow proper serializability of the operator.
  @transient
  private var evaluator: Evaluator = null

jwalton

Graphing Widget

The graphing widget shows graphs using the Rickshaw graphing library. The names of data fields should be (vaguely) familiar if you've used Rickshaw before.

It's recommended that you replace the /assets/javascripts/rickshaw.min.js from your dashboard with the latest from here.

Supported HTML data fields

MLnick

import spark.streaming.StreamingContext._
import spark.streaming.{Seconds, StreamingContext}
import spark.SparkContext._
import spark.storage.StorageLevel
import spark.streaming.examples.twitter.TwitterInputDStream
import com.twitter.algebird.HyperLogLog._
import com.twitter.algebird._

/**
 * Example of using HyperLogLog monoid from Twitter's Algebird together with Spark Streaming's