Resultados da pesquisa a pedido "scala"
Qual é a diferença entre Try e Either?
De acordo coma documentação [http://www.scala-lang.org/api/2.11.4/index.html#scala.util.Try]: O tipo Try representa um cálculo que pode resultar em uma exceção ou retornar um valor calculado com êxito. É semelhante, mas semanticamente diferente ...
Como remover parênteses em torno de registros quando saveAsTextFile no RDD [(String, Int)]?
estou a usarsaveAsTextFile(path) para salvar a saída como arquivo de texto posteriormente para importar o resultado para o DB. A saída é mais ou menos assim: (value1, value2)Como remover os parênteses?
java.sql.SQLException: nenhum driver adequado encontrado ao carregar o DataFrame no Spark SQL
Estou atingindo um problema muito estranho ao tentar carregar o JDBC DataFrame no Spark SQL. Eu tentei vários clusters Spark - YARN, cluster autônomo e modo pseudo-distribuído no meu laptop. É reproduzível no Spark 1.3.0 e 1.3.1. O problema ...
Como implementar o observeLatestOn no RxJava (RxScala)?
Estou tentando implementar oObserveLatestOn [https://social.msdn.microsoft.com/Forums/en-US/bbcc1af9-64b4-456b-9038-a540cb5f5de5/how-do-i-ignore-allexceptthelatest-value-when-my-subscribe-method-is-running?forum=rx>] operador em RxJava (na ...
Como calcular o inverso de um RowMatrix no Apache Spark?
Eu tenho um X, matriz distribuída, no formato RowMatrix. Estou usando o Spark 1.3.0. Eu preciso ser capaz de calcular X inverso.
O console scala do Intellij não está funcionando
Acabei de atualizar meu plugin IntelliJ e scala e agora o console scala não funcionará (ou seja,Ctrl+Entrar não afeta). Versão Intellij:14.1.1 Versão do plugin Scala1.4.15
Slick 3.0-RC3 falha com java.util.concurrent.RejectedExecutionException
Estou tentando me familiarizar com o Slick 3.0 e o Futures (usando o Scala 2.11.6). Eu uso código simples baseado emExemplo de padrão de bolo Multi-DB do Slick [http://typesafe.com/activator/template/slick-multidb-3.0]. Por que o código a seguir ...
Uso adequado de características Scala e objetos de caso
Tentando entender as classes e os traços do Scala, aqui está um exemplo simples. Quero definir uma classe que especifique uma variedade de operações, que podem ser implementadas de várias maneiras. Eu posso começar com sealed trait Operations{ ...
Como comparar todos os elementos no RDD com todos os outros elementos no RDD?
Estou tentando realizar uma pesquisa de vizinhos K mais próxima usando o spark. Eu tenho um RDD [Seq [Double]] e estou planejando retornar um RDD [(Seq [Double], Seq [Seq [Double]])] com a linha real e uma lista de vizinhos val out = ...
java.lang.NoSuchMethodError Jackson databind and Spark
Estou tentando executar o envio de spark com o Spark 1.1.0 e o Jackson 2.4.4. Eu tenho código scala que usa Jackson para desserializar JSON em classes de caso. Isso funciona bem por si só, mas quando o uso com o spark, recebo o ...