Resultados da pesquisa a pedido "scala"
scala Remove (no lugar) todos os elementos de um ListBuffer que atendem a uma condição
Eu tenho um ListBuffer. Quero remover todos os elementos que atendem a uma determinada condição. Eu poderia iterar sobre ele e remover cada elemento. Mas o que Scala diz sobre mudar uma lista que você está repetindo? Funcionará ou excluirá os ...
Spark UDAF com ArrayType como bufferSchema problemas de desempenho
Estou trabalhando em um UDAF que retorna uma matriz de elementos. A entrada para cada atualização é uma tupla de índice e valor. O que o UDAF faz é somar todos os valores no mesmo índice. Exemplo: Para entrada (índice, valor): (2,1), (3,1), ...
@transient preguiçoso val serial serialização
Eu tenho um problema no Scala. Eu serializo uma instância da classe com@transient lazy val campo. E então eu desserializá-lo, o campo é atribuídonull. Espero a avaliação preguiçosa após a desserialização. O que devo fazer? A seguir está um ...
Como lidar com linhas de várias linhas no spark?
Estou tendo um quadro de dados que possui algumas observações de várias linhas: +--------------------+----------------+ | col1| col2| +--------------------+----------------+ |something1 |somethingelse1 | |something2 |somethingelse2 | |something3 ...
como injetar dependências em um serviço com o MacWire (play framework)
Eu tenho uma classe de serviço, e o serviço tem um métodogetSomethingFromApi , agora, quero ter a instância play Configuration para poder extrair coisas do application.conf e um WSClient play para poder executar chamadas http. é assim que eu ...
Como obtenho uma instância da classe de tipo associada a um contexto vinculado?
Nota: Estou fazendo esta pergunta para responder a mim mesmo, mas outras respostas são bem-vindas. Considere o seguinte método simples: def add[T](x: T, y: T)(implicit num: Numeric[T]) = num.plus(x,y)Eu posso reescrever isso usando umlimite de ...
Spark Structured Streaming - Processando cada linha
Estou usando o streaming estruturado com o Spark 2.1.1. Preciso aplicar alguma lógica de negócios às mensagens recebidas (da fonte Kafka). essencialmente, preciso captar a mensagem, obter alguns valores-chave, procurá-los no HBase e executar ...
Como construir o Dataframe a partir de um arquivo do Excel (xls, xlsx) no Scala Spark?
Eu tenho um grandeExcel(xlsx and xls) arquivo com várias folhas e preciso convertê-lo paraRDD ouDataframe para que possa ser associado a outrosdataframe mais tarde. Eu estava pensando em usarApache POI [https://poi.apache.org/]e salve-o comoCSV e ...
Quais decisões de design favoreceriam os atores da Scala em vez do JMS?
Quais são as diferenças usando os atores Scala em vez do JMS? Por exemplo, de uma perspectiva de desempenho e escalabilidade, o que o modelo Scala Actor adiciona comparado ao JMS? Em quais casos faz mais sentido usar os Atores em vez do JMS, ou ...
Substituindo operadores aritméticos no Int por meio de conversões implícitas
Diga que, por razões estéticas, eu quero ser capaz de escrever: 3 / 4e tenha / seja um método em uma classe em que exista uma conversão implícita de Int para, por exemplo: class Foo(val i: Int) { def /(that: Int) = // something } implicit ...