| sealed abstract class QueryType[T] { | |
| val data: T | |
| } | |
| case class IntQueryType(data: Int) extends QueryType[Int] with Ordered[IntQueryType] { | |
| def compare(that: IntQueryType): Int = this.data - that.data | |
| } | |
| case class StringQueryType(data: String) extends QueryType[String] with Ordered[StringQueryType] { | |
| def compare(that:StringQueryType):Int = this.data.compareTo(that.data) |
| trait Animal | |
| case class Bird(name: String, wings: Boolean) extends Animal | |
| case class Horse(name: String, height: Double) extends Animal | |
| object Animal { |
I hereby claim:
To claim this, I am signing this object:
| ################ TEST RUN 1 Java 8 Async Receiver ########################### | |
| java -jar target/cqltestclient.jar --host=127.0.0.1 --activity=WriteTelemetryAsync:7000000:150:1500 --activity=ReadTelemetryAsync:700000:50:500 | |
| 5/4/15 9:16:55 PM ============================================================== | |
| -- Counters -------------------------------------------------------------------- | |
| ActivityExecutorService.activities | |
| count = 2 | |
| ReadTelemetryAsyncActivity.async-pending |
| class DseSparkContextFactory extends SparkContextFactory { | |
| import SparkJobUtils._ | |
| type C = SparkContext with ContextLike | |
| def makeContext(config: Config, contextConfig: Config, contextName: String): C = { | |
| val conf = configToSparkConf(config, contextConfig, contextName) | |
| val sparkMaster = "dsetool sparkmaster".!!.trim | |
| conf.set("spark.master",sparkMaster) |
| import scala.annotation.tailrec | |
| def atoi(chList:List[String]):Int = { | |
| @tailrec | |
| def atoiAccumulator(chList: List[String], accumulator: Int): Int = chList match { | |
| case Nil => accumulator | |
| case head :: tail => | |
| val tensMult = scala.math.pow(10, tail.length).toInt | |
| val nxtAccumulator = (head.toInt * tensMult) + accumulator |
| import org.apache.spark.streaming.kafka.KafkaUtils | |
| import org.apache.spark.streaming.Time | |
| import kafka.serializer.StringDecoder | |
| import org.joda.time.DateTime | |
| import org.apache.spark.sql.SaveMode | |
| import sqlContext.implicits._ | |
| val ratingsStream = KafkaUtils.createDirectStream[String, String, StringDecoder, StringDecoder](ssc, kafkaParams, topics) | |
| val msgs = ratingsStream.transform { |
| override val supervisorStrategy: SupervisorStrategy = { | |
| val decider: SupervisorStrategy.Decider = { | |
| case Guest.CaffeineException => | |
| SupervisorStrategy.Stop | |
| case Waiter.FrustratedException(coffee, guest) => | |
| barista.tell(Barista.PrepareCoffee(coffee, guest), sender()) | |
| SupervisorStrategy.Restart | |
| } | |
| OneForOneStrategy()(decider orElse super.supervisorStrategy.decider) | |
| } |
I hereby claim:
To claim this, I am signing this object:
| 15kX9REWJS9v3NmT1JeeUN6NnovQk9WnWz |