Resultados da pesquisa a pedido "scala"
No Spark, qual é a maneira correta de ter um objeto estático em todos os trabalhadores?
Eu estive olhando a documentação do Spark e menciona isso: A API do Spark depende muito da passagem de funções no programa de driver para execução no cluster. Existem duas maneiras recomendadas de fazer isso: Sintaxe de função anônima, que pode ...
Akka Design Principals
Enquanto trabalhava em um aplicativo Akka bastante amplo, deparei-me com uma estrutura muito simples ao trabalhar com métodos normais e classes não Akka, mas que são realmente difíceis de identificar ao trabalhar com o Akka, e é por isso que vim ...
Mapeie e reduza / dobre a HList do scalaz.Validation
Comecei com algo assim: def nonEmpty[A] = (msg: String) => (a: Option[A]) => a.toSuccess(msg) val postal: Option[String] = request.param("postal") val country: Option[String] = request.param("country") val params = (postal |> ...
Como converter Scala RDD em Mapa
Eu tenho um RDD (array de String)org.apache.spark.rdd.RDD[String] = MappedRDD[18] e convertê-lo em um mapa com IDs exclusivos. Eu fiz 'val vertexMAp = vertices.zipWithUniqueId"mas isso me deu outro RDD do tipo'org.apache.spark.rdd.RDD[(String, ...
Exemplo de execução do spark scala falha
Eu sou novo no Spark e no Scala. Criei um projeto IntelliJ Scala com o SBT e adicionei algumas linhas ao build.sbt. name := "test-one" version := "1.0" scalaVersion := "2.11.2" libraryDependencies += "org.apache.spark" % "spark-core_2.10" % ...
A conversão implícita do json do Play 2.3 causa exceção de ponteiro nulo
Estou tentando analisar json na minha classe de casoDealFormMap case class DealFormMap(limit: Option[Int], filter: Option[DealFormFilterMap]) case class DealFormFilterMap(date: Option[String], code: Option[String]) implicit val dealFormMapReads: ...
Pode um loop while ser usado com rendimento em scala
Aqui está o formato padrão para um for / yield no scala: observe que ele espera uma coleção - cujos elementos conduzem a iteração. for (blah <- blahs) yield someThingDependentOnBlahEu tenho uma situação em que um número indeterminado de ...
Existe Future.find seqüencial?
Eu tenho alguma função com efeito colateral, def f(): Future[Int] = { val n = Random.nextInt() println(s"Generated $n") Future(n) }e quero executá-lo repetidamente até que o predicado retorne verdadeiro. def success(n: Int): Boolean = n % 2 == ...
Como dividir uma lista [A, B]
Eu quero dividir umList[Either[A, B]] em duas listas. Existe uma maneira melhor ? def lefts[A, B](eithers : List[Either[A, B]]) : List[A] = eithers.collect { case Left(l) => l} def rights[A, B](eithers : List[Either[A, B]]) : List[B] ...
como instanciar a unidade no Scala?
Tudo o que desejo é usar um conjunto simultâneo (que parece não existir). Usos Javajava.util.concurrent.ConcurrentHashMap<K, Void> para alcançar esse comportamento. Eu gostaria de fazer sth similar no Scala, então criei a instância do Scala ...