Resultados da pesquisa a pedido "scala"

1 a resposta

Como definir uma variável global de escala no Spark que será compartilhada por todos os trabalhadores?

No programa Spark, QUERO definir uma variável como um mapa imutável que será acessado por todos os programas de trabalho de forma síncrona, o que posso fazer? Devo definir um objeto scala? Não apenas mapa imutável, e se eu quiser uma variável ...

10 a resposta

Como converter objeto rdd em dataframe no spark

Como posso converter um RDD (org.apache.spark.rdd.RDD[org.apache.spark.sql.Row]) para um Dataframeorg.apache.spark.sql.DataFrame. Eu converti um dataframe para rdd usando.rdd. Depois de processá-lo, quero-o novamente no dataframe. Como posso ...

16 a resposta

Como alterar os tipos de coluna no DataFrame do Spark SQL?

Suponha que eu esteja fazendo algo como: val df = sqlContext.load("com.databricks.spark.csv", Map("path" -> "cars.csv", "header" -> "true")) df.printSchema() root |-- year: string (nullable = true) |-- make: string (nullable = true) |-- model: ...

2 a resposta

Como converter chaves em um mapa para minúsculas?

Eu tenho um mapa onde a chave é uma String e preciso alterar todas as chaves para minúsculas antes de trabalhar com este mapa. Como posso fazer isso no Scala? Eu estava pensando em algo como: var newMap = scala.collection.mutable.Map[String, ...

1 a resposta

Transmitir uma variável ao tipo de tempo de execução do TypeCast existencial digitado no Scala

Esta discussão [https://stackoverflow.com/questions/29380839/trait-runtime-type-of-type-parameter-through-typetag-when-used-with-existential] abordado como usarTypeTag para obter o tipo de tempo de execução dos parâmetros de tipo quando usado ...

2 a resposta

Tipo de coleção gerado por for with yield

Quando eu avalio umfor em Scala, eu tenho um imutávelIndexedSeq (uma coleção com características de desempenho do tipo matriz, como acesso aleatório eficiente): scala> val s = for (i <- 0 to 9) yield math.random + i ...

2 a resposta

O que é um TrieMap e quais são suas vantagens / desvantagens em comparação com um HashMap?

Scala tem uma coleção TrieMap. O que é um TrieMap e quais são suas vantagens / desvantagens em comparação com um HashMap?

2 a resposta

Preenchendo o menu suspenso com os valores do banco de dados no trabalho de quadro de reprodução

Eu sou novo em trabalhar com molduras e estou achando um pouco difícil. Estou recuperando a lista de nomes de clientes da base de dados e preenchendo-a para uma lista suspensa, aqui está o meu código client.java package models; import ...

1 a resposta

Como usar o valor constante no UDF do Spark SQL (DataFrame)

Eu tenho um quadro de dados que incluitimestamp. Para agregar por hora (minuto, hora ou dia), tentei como: val toSegment = udf((timestamp: String) => { val asLong = timestamp.toLong asLong - asLong % 3600000 // period = 1 hour }) val df: ...

1 a resposta

Por que não consigo criar um objeto delimitado por F no Scala

Suponha que eu tenha: trait A[AA <: A[AA]] //or even just ` trait A[AA]Isso não funciona: scala> object AAA extends A[AAA.type] <console>:8: error: illegal cyclic reference involving object AAA object AAA extends A[AAA.type] ^Mas ...