tues

#!/usr/bin/env python

# Usage:
#   $ scapy_nailgun.py example.pcap
# Creating the pcap with tcpdump:
#   $ tcpdump -w example.pcap -i lo tcp port 8212
# Output format is:
#   [sender:port | type | length] content
# where:
#   sender - 'C' for client, 'S' for server

tues

  implicit object OptionalStringReads extends Reads[Option[String]] {
    def reads(json: JsValue) = json match {
      case JsString(s) => JsSuccess(Some(s))
      case JsNull      => JsSuccess(None)
      case _           => JsError("error.expected.jsstring")
    }
  }

tues

import org.apache.spark.SparkContext
import org.apache.spark.SparkContext._
import org.apache.spark.SparkConf

import org.yaml.snakeyaml.Yaml
import org.yaml.snakeyaml.constructor.Constructor
import scala.collection.mutable.ListBuffer
import scala.beans.BeanProperty

object Main {

tues

import scala.concurrent.ExecutionContext.Implicits.global
import reactivemongo.bson.BSONObjectID
import reactivemongo.bson.BSONDocument
import scala.concurrent.Future

object Main {

  def main(args: Array[String]): Unit = {
    val driver = new reactivemongo.api.MongoDriver
    val connection = driver.connection(List("localhost"))