Dino Fancellu fancellu

## index.html

<html>
    <head>
            <!-- Do you need Material Icons? -->
        <link href="https://fonts.googleapis.com/css?family=Roboto:100,300,400,500,700,900|Material+Icons" rel="stylesheet" type="text/css">

        <link href="https://cdn.jsdelivr.net/npm/quasar/dist/quasar.min.css" rel="stylesheet" type="text/css">
    </head>

    <body>

## RowParser.scala
case class Row(rowstring: String)

trait RowParse[A]{
  def parse(row:Row):A
}

case class TwoPart(v1: String, v2: String)

case class ThreePart(v1: String, v2: String, v3: String)

## Censor.scala
import ujson.{ Obj, Value }

object Censor{

def updateAll(root: Value, target: (String => Boolean), newValue: Value): Value = {

    def update(value: Value, parent: Value = null, valueName: String = null): Unit = {
      value match {
        case Obj(values) =>
          values.map { case (name, v) => update(v, value, name) }

## FoldingValidationExamples.scala
import scala.util.{Failure, Try}

val li=List(1,2,3,4)

type Transform[F[_],A]=F[A] => F[A]

def filterSmall: Transform[Try,Int] ={ ti=>
  ti.flatMap(i=>if (i>1) Try(i) else new Failure(new Exception(s"$i is too small")))
}

## keybase.md

      
              1 file
            
          
              0 forks
            
          
              0 comments
            
          
              0 stars
            
          
                fancellu
                / keybase.md
            
            
              Created Nov 3, 2018
            
          
      View keybase.md
  
    
    Keybase proof
I hereby claim:

I am fancellu on github.
I am fancellu (https://keybase.io/fancellu) on keybase.
I have a public key ASAIwD1-6lC-FAdHSUyefT5Xul7zEulj3OlQnMZ7uGYBtAo

To claim this, I am signing this object:

  
## TryFlatten.scala
import scala.util.{Success, Failure}

val seq=Seq(Success(1), Failure(new Exception("bang")), Success(2))

// all emit         List(1, 2)

seq.map(_.toOption).flatten
seq.flatMap(_.toOption)
seq.filter(_.isSuccess).map(_.get)
seq.collect{case Success(x) => x}

## .block
license: gpl-3.0
height: 600

## InfiniteStreamReceiver.scala
/**
  * Allows you to receive scala.collection.immutable.Stream
  */

import org.apache.spark.storage.StorageLevel
import org.apache.spark.streaming.receiver.Receiver

class InfiniteStreamReceiver[T](stream: Stream[T], delay:Int=0, storageLevel: StorageLevel) extends Receiver[T](storageLevel) {

  receiver=>

## ES.scala
// https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/_maven_repository.html
// Play 2.5 is not compatible with ES 5.x Java TCP, as ES demands Netty 4.1 vs Play's 4.0
// https://github.com/sksamuel/elastic4s/issues/672

import org.apache.http.HttpHost
import org.apache.http.entity.ContentType
import org.apache.http.nio.entity.NStringEntity
import org.apache.http.util.EntityUtils
import org.elasticsearch.client.RestClient
import play.api.libs.json.{Format, Json, Writes}

## Module.scala
import actors.ActorBrowserActor
import com.google.inject.AbstractModule
import play.api.libs.concurrent.AkkaGuiceSupport

class Module extends AbstractModule with AkkaGuiceSupport{
  def configure(): Unit = {
    bindActor[ActorBrowserActor](ActorBrowserActor.NAME, _=>ActorBrowserActor.props)
  }
}