| trait AbcService with UnhandledRouteDebug { | |
| override def receive: Actor.Receive = runRoute(logRequestResponse(myLog _) { | |
| staticRoute ~ internalRoutes ~ routes | |
| }) | |
| } | |
| trait UnhandledRouteDebug { | |
| def myLog(request: HttpRequest): Any => Option[LogEntry] = { | |
| case x: HttpResponse => { | |
| println (s"Normal: $request") |
| import spray.routing.HttpService | |
| import spray.httpx.SprayJsonSupport | |
| import scala.concurrent.ExecutionContext | |
| trait StaticWebService extends HttpService with SprayJsonSupport { | |
| implicit def executor: ExecutionContext | |
| def staticRoute = | |
| pathPrefix("swagger") { |
This simple script will take a picture of a whiteboard and use parts of the ImageMagick library with sane defaults to clean it up tremendously.
The script is here:
#!/bin/bash
convert $1 -morphology Convolve DoG:15,100,0 -negate -normalize -blur 0x1 -channel RBG -level 60%,91%,0.1 $2
| package foo.bar | |
| import spray.routing._ | |
| import spray.http._ | |
| import spray.http.StatusCodes.Forbidden | |
| // See https://developer.mozilla.org/en-US/docs/HTTP/Access_control_CORS | |
| case class Origin(origin: String) extends HttpHeader { |
| trait Monoid[A] { | |
| def append(a1: A, a2: A): A | |
| def empty: A | |
| } | |
| object Monoid { | |
| implicit def ListMonoid[A]: Monoid[List[A]] = new Monoid[List[A]] { | |
| def append(a1: List[A], a2: List[A]) = a1 ::: a2 | |
| def empty = Nil | |
| } |
| SonarQube Runner 2.4 | |
| Java 1.7.0_55 Oracle Corporation (64-bit) | |
| Linux 3.8.0-38-generic amd64 | |
| INFO: Error stacktraces are turned on. | |
| INFO: Runner configuration file: /home/user/Downloads/sonar-runner-2.4/conf/sonar-runner.properties | |
| INFO: Project configuration file: /tmp/sonar-scoverage-plugin/samples/sbt/multi-module/sonar-project.properties | |
| INFO: Default locale: "en_GB", source code encoding: "UTF-8" (analysis is platform dependent) | |
| INFO: Work directory: /tmp/sonar-scoverage-plugin/samples/sbt/multi-module/./.sonar | |
| INFO: SonarQube Server 4.3 | |
| 14:39:07.867 INFO - Load batch settings |
More patches can be found here: https://github.com/willb/spark-packaging
| case class Task(a: Int, b: Int) | |
| case class TaskResult(result: Int) | |
| class Collector(worker: ActorRef) extends Actor { | |
| def receive = { | |
| case task: Task => worker ! task | |
| case TaskResult(r) => println(s"Got result: $r") | |
| } | |
| } |
| ./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker -zkconnect zookeeper.host:2181/external/kasia/kafka --group SparkStreamingJob-com.company.PurchaseEventSparkStreaming |