Resultados da pesquisa a pedido "scala"
Conversão implícita entre coleções java e scala usando JavaConversions
Eu fundei uma scalaSet de scalaMaps usando uma função genérica def mergeMaps[A, B](ms: Set[Map[A, B]])(f: (B, B) => B): Map[A, B] = (Map[A, B]() /: (for (m <- ms; kv <- m) yield kv)) { (a, kv) => a + (if (a.contains(kv._1)) kv._1 -> f(a(kv._1), ...
Não pode empurrar para o heroku
Eu estava colocando o repositório git atual no heroku. Esse aplicativo on-line foi desenvolvido usando Scala e IntelliJ. E não sei como corrigir esse erro. $ git push heroku master Counting objects: 3, done. Delta compression using up to 4 ...
Falha ao inicializar o compilador: objeto java.lang.Object no espelho do compilador não encontrado
No Ubuntu 16.04, instaleiscala: $ls ~/Binary/scala-2.11.8 bin doc lib man $grep -A 2 SCALA ~/.bashrc SCALA=~/Binary/scala-2.11.8 SBT=~/Binary/sbt export PATH=$PATH:$SCALA/bin:$SBT/binComopenjdk8 instalado,scala falha ao abrir o REPL: $javac ...
Como fazer um segmento de código seguro em scala?
Eu tenho um código no scala que, por várias razões, tem poucas linhas de código que não podem ser acessadas por mais threads ao mesmo tempo.Como facilmente t...
Maneira correta de parar o Akka Streams sob condição
Eu tenho usado com sucessoFileIO [http://doc.akka.io/api/akka/2.4/?_ga=1.140568374.588201913.1464855311#akka.stream.scaladsl.FileIO$] para transmitir o conteúdo de um arquivo, calcule algumas transformações para cada linha e agregue / reduza os ...
Leia o tópico Kafka em uma tarefa em lote do Spark
Estou escrevendo um trabalho em lotes Spark (v1.6.0) que lê de um tópico Kafka. Para isso eu posso usarorg.apache.spark.streaming.kafka.KafkaUtils#createRDD no entanto, preciso definir os deslocamentos para todas as partições e ...