Resultados da pesquisa a pedido "scala"
Scala para Java (programação funcional)
Me pediram para 'traduzir' algum código Scala para Java para um curso. No entanto, os requisitos da atribuição são que Java 8 e bibliotecas externas, como Java funcional [http://www.functionaljava.org]eTotalmente ...
Como criar um transformador personalizado a partir de um UDF?
Eu estava tentando criar e salvar umPipeline [https://spark.apache.org/docs/latest/api/scala/index.html#org.apache.spark.ml.Pipeline] com estágios personalizados. Preciso adicionar umcolumn para o meuDataFrame usando umUDF. Portanto, eu queria ...
Minha ação PlayFramework retorna antes que um futuro esteja pronto. Como atualizo um componente da página da web?
Eu tenho uma função Scala PlayFramework que chama MongoDB e obtém umFuture[Seq[Document]] resultado. Após um evento de zoom / panorâmica do mapa, este PlayAction A função é chamada de JavaScript em uma página da web via xhttp / GET. O método My ...
Como calcular a soma acumulada usando o Spark
Eu tenho um rdd de (String, Int), que é classificado por chave val data = Array(("c1",6), ("c2",3),("c3",4)) val rdd = sc.parallelize(data).sortByKeyAgora, quero iniciar o valor da primeira chave com zero e as chaves subseqüentes como soma das ...
usando a instrução preparada várias vezes, avisando Cassandra Querying Reducing Performance
Estou obtendo dados de algum lugar e inserindo-os nocassandra diariamente, então eu preciso recuperar os dados decassandra durante toda a semana e faça algum processamento e insira o resultado novamentecassandra. Eu tenho muitos registros, cada ...
uma expressão do tipo Nulo não é elegível para conversão implícita
Ao fazer isso: def myfunction(line: String): (Int, Option[DateTime], Option[Int]) = { // do some stuff (5, Option(null), Option(null)) }Eu recebo o seguinte: uma expressão do tipo Nulo não é elegível para conversão implícita Não tenho certeza ...
Por que as letras maiúsculas não podem ser usadas para correspondência de padrões para definir valores?
Por que posso usar letras minúsculas para nomes: val (a, bC) = (1, 2) (1, 2) match { case (a, bC) => ??? }e não pode usar letras maiúsculas: /* compile errors: not found: value A, BC */ val (A, BC) = (1, 2) /* compile errors: not found: value ...
Aplicando a Função à Coluna Spark Dataframe
Vindo de R, estou acostumado a fazer operações facilmente em colunas. Existe alguma maneira fácil de executar essa função que eu escrevi no scala def round_tenths_place( un_rounded:Double ) : Double = { val rounded ...
Resultados inesperados no Spark MapReduce
Eu sou novo no Spark e quero entender como o MapReduce é realizado sob o capô para garantir que eu o use corretamente.Esta postagem [https://stackoverflow.com/a/32520848/5880417]forneceu uma ótima resposta, mas meus resultados parecem não seguir ...
Spark: diferença de semântica entre reduzir e reduzirByKey
Na documentação do Spark, diz que o método RDDsreduce [http://spark.apache.org/docs/latest/api/scala/index.html#org.apache.spark.rdd.RDD] requer uma função binária associativa e comutativa. No entanto, o ...