Resultados da pesquisa a pedido "scala"
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 ...
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 ...
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: ...
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, ...
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 ...
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 ...
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?
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 ...
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: ...
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 ...