Resultados da pesquisa a pedido "scala"
Scala genéricos: como declarar que um tipo deve ser uma classe de caso?
Eu tenho várias classes de casos com umcount campo. É 1 por padrão, e eu tenho uma redução no meu código que agrupa duplicatas e somas que valorizam para encontrar o número de cada objeto. Por exemplo.: case class Person(name: String, count = ...
Implementação do Akka-Stream mais lenta que a implementação de thread único
ATUALIZAÇÃO DE 30-10-2015 baseado em Roland Kuhn Awnser: O Akka Streams está usando a passagem assíncrona de mensagens entre os atores para implementar estágios de processamento do fluxo. A passagem de dados através de um limite assíncrono tem ...
Como você zomba do nome de chamada scala no Mockito
Estou tentando zombar do método scala call-by name no mockito. Mas encontrando esse erro. Essa exceção pode ocorrer se os correspondentes forem combinados com valores brutos: // incorreto: someMethod (anyObject (), "raw String"); Ao usar ...
Como adicionar um Spark Dataframe na parte inferior de outro dataframe?
Eu posso usarwithcolumnpara adicionar novas colunas a um Dataframe. Mas no scala como posso adicionar novas linhas a um DataFrame? Estou tentando adicionar um quadro de dados na parte inferior de outro. Portanto, como adicionar linhas no scala ...
Uma variável usada em sua própria definição?
Um fluxo infinito: val ones: Stream[Int] = Stream.cons(1, ones) Como é possível que um valor seja usado em sua própria declaração? Parece que isso deve produzir um erro do compilador, mas funciona.
Ignorar a primeira linha de cada arquivo no Spark (Scala)
Estou processando uma pasta S3 contendo arquivos csv.gz no Spark. Cada arquivo csv.gz possui um cabeçalho que contém nomes de colunas. A maneira como carrego os dados contidos no Spark é fazer referência ao caminho / pasta, assim: val rdd = ...
Como remover o spray jsonFormat
Estou implementando alguma API de descanso que usa spray e akka. A API deve expor algum tipo de usuário CRUD. Vou usar apenas criar usuário nesta pergunta ... case class User(id:String, name:String) case class ...
Derivando instâncias de classe de tipo para classes de caso com exatamente um campo
Estou trabalhando em uma biblioteca de análise CSV (tabular [http://nrinaudo.github.io/tabulate/]) Ele usa classes de tipo simples para codificação / decodificação: a codificação, por exemplo, é feita com instâncias deCellEncoder (para codificar ...
Transmissão em slick / scala
Estou olhando para o scala / slick streaming e tentando entender como funciona. Aqui está o meu código de teste val bigdata = TableQuery[BigData] val x = db.stream(bigdata.result.transactionally.withStatementParameters(fetchSize = 100)).foreach ...
Atribuição múltipla Scala à variável existente
Eu posso fazer algo como def f(): Tuple2[String, Long] = ... val (a, b) = f()E se as variáveis já existirem? Estou executando os mesmos conjuntos de dados por filtros e não quero encadeá-los (nomes longos e outros). Foi isso que tentei, mas ...