Resultados da pesquisa a pedido "scala"
Como usar as funções collect_set e collect_list na agregação de janelas no Spark 1.6?
No Spark 1.6.0 / Scala, há uma oportunidade de obtercollect_list("colC") oucollect_set("colC").over(Window.partitionBy("colA").orderBy("colB")?
Como criar o projeto Spark / Scala no IntelliJ IDEA (falha ao resolver dependências no build.sbt)?
Estou tentando criar e executar um projeto Scala / Spark no IntelliJ IDEA. Eu adicioneiorg.apache.spark:spark-sql_2.11:2.0.0 em bibliotecas globais e meubuild.sbt se parece abaixo. name := "test" version := "1.0" scalaVersion := "2.11.8" ...
Scala: Verifique se os aparelhos estão equilibrados
Estou executando um código para equilibrar colchetes no extrato. Acho que entendi direito, mas está falhando em uma afirmação específica, preciso entender o porquê? Este é o teste em particular que está falhando "()) (" Mais do que a ...
Como as corotinas são implementadas nos idiomas da JVM sem suporte à JVM?
Esta questão surgiu depois de ler oProposta de tear [http://cr.openjdk.java.net/~rpressler/loom/Loom-Proposal.html], que descreve uma abordagem de implementação de corotinas na linguagem de programação Java. Particularmente, essa proposta diz ...
Por que o Numérico se comporta de maneira diferente do Pedido?
O Scala possui várias características que você pode usar como classes de tipo, por exemploOrdered eNumeric Na embalagemscala.math. Eu posso, por exemplo, escrever um método genérico usandoOrdered como isso: def f[T <% Ordered[T]](a: T, b: T) = ...
o que é o método apply em Scala, usado especialmente na definição de tipo
Eu sei dissoapply O método é açúcar sintático quando usado no objeto complementar. No entanto, o que éapply método para quando é usado na definição de tipo, assim como abaixo? type Applyn = { def apply[A](f: A=>A, n: Int, x: A): A }Existe uma ...
A associação automática não está funcionando conforme o esperado com a API DataFrame
Estou tentando obter os registros mais recentes de uma tabela usando a associação automática. Funciona usandospark-sql mas não está trabalhando usando faíscaDataFrame API. Alguém pode ajudar? Isso é um bug? Estou usando o Spark 2.2.0 no modo ...
Os auxiliares de teste do Play Framework precisam de `Materializer` implícito
Estou usando o Play 2.6.xe o auxiliar de teste parastatus(result) tem o método: def status(of: Accumulator[ByteString, Result])(implicit timeout: Timeout, mat: Materializer): Int = status(of.run()) A execução de testes é lançada quando o ...
Maneira simples de aplicar uma lista de funções a um valor
Suponha que eu tenha uma lista de funçõesList[A => B] e precisa de uma função que retorneList[B] para um determinado valor do tipoA: def foo[A, B](fs: List[A => B]): A => List[B] = a => fs.map(_.apply(a))Existe algum mais simples (talvez ...
Como transformar o quadro de dados em vetor de recurso de rótulo?
Estou executando um modl de regressão logística no scala e tenho um quadro de dados como abaixo: df +-----------+------------+ |x |y | +-----------+------------+ | 0| 0| | 0| 33| | 0| 58| | 0| 96| | 0| 1| | 1| 21| | 0| 10| | 0| 65| | 1| 7| | 1| ...