Resultados da pesquisa a pedido "scala"

5 a resposta

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 ...

6 a resposta

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?

4 a resposta

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 ...

2 a resposta

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 ...

3 a resposta

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.

1 a resposta

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

1 a resposta

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 ...

1 a resposta

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{ ...

1 a resposta

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 = ...

5 a resposta

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 ...