Resultados da pesquisa a pedido "scala"
Como zombar de um ator da Akka para testar uma unidade?
Eu tenho uma classe Controller que controla os pedidos enviados para um ator Akka que é injetado no controlador. Código do controlador: class Controller(actor: ActorRef) { def control(msg: String): Future[String] = { actor.ask(msg)(Timeout(2 ...
Existe uma maneira de obter as primeiras 1000 linhas de um Dataframe Spark?
Estou usando orandomSplitpara obter uma pequena quantidade de um dataframe para uso em props dev e acabo pegando o primeiro df retornado por essa função. val df_subset = data.randomSplit(Array(0.00000001, 0.01), seed = 12345)(0)Se ...
Como agregar valores na coleção após groupBy?
Eu tenho um quadro de dados com esquema como tal: [visitorId: string, trackingIds: array<string>, emailIds: array<string>] Procurando uma maneira de agrupar (ou talvez acumular?) Esse quadro de dados por visitorid, onde as colunas trackingIds e ...
Por que a compilação sbt falha com StackOverflowError?
Estou trabalhando em um projeto Scala que existe há alguns anos, mas é novo para mim. Minha tarefa é atualizá-lo do Scala 2.9.3 para 2.11.7, juntamente com suas dependências. Passei pelos erros e avisos, mas não consigo compilar o projeto com ...
Representar parâmetros aninhados para a consulta Neo4j no Scala
Tentei executar consultas Neo4j com parâmetros na forma do mapa [String, Anyref], que funciona muito bem. No entanto, gostaria de enviar os dados para o Neo4j no formato do lote, para que o resultado fosse Map [String, Map [String, AnyRef]] ou ...
Cache de resolução implícita
Para reduzir o tempo de compilação do meu projeto, estou armazenando em cache determinadas classes de tipos que são resolvidas por pesquisas implícitas. Isso parece um tanto complicado, porque a implementação direta não funciona: scala> implicit ...
Como usar várias versões de uma biblioteca no Scala?
Estou usando uma biblioteca, digamos A, no Scala, que depende da versão x.11 de outra biblioteca, digamos Z. Agora, também estou usando uma biblioteca, digamos B, que depende da versão x.31 do Z. Isso leva ao erro de compilação porque teremos ...
Por que implementar o método abstrato usando val e call da superclasse na expressão val retorna NullPointerException
Eu tenho uma classe abstrata com um método não implementadonumbers que retorna uma lista de números e esse método é usado em outra inicialização de propriedade val: abstract class Foo { val calcNumbers = numbers.map(calc) def ...
Por que o Functor [A =>?] Não é compilado no Scala 2.11.7?
Eu estou seguindoA excelente introdução de Michael Pilquist para Functors [https://www.youtube.com/watch?v=Dsd4pc99FSY&t=21m57s]e meu Scala 2.11.7 repl falha ao compilar (interpretar?) a seguinte linha. implicit def function1Functor[X]: ...
O que é RDD no Spark
A definição diz: RDD é uma coleção distribuída imutável de objetos Não entendo bem o que isso significa. São como dados (objetos particionados) armazenados no disco rígido? Em caso afirmativo, como os RDDs podem ter classes definidas pelo ...