Resultados da pesquisa a pedido "scala"

3 a resposta

Conversão implícita, importação necessária ou não?

Eu escrevo object MyString { implicit def stringToMyString(s: String) = new MyString(s) } class MyString(str: String) { def camelize = str.split("_").map(_.capitalize).mkString override def toString = str } object Parse { def main(args: ...

5 a resposta

Como resolver o AnalysisException: atributo (s) resolvido (s) no Spark

val rdd = sc.parallelize(Seq(("vskp", Array(2.0, 1.0, 2.1, 5.4)),("hyd",Array(1.5, 0.5, 0.9, 3.7)),("hyd", Array(1.5, 0.5, 0.9, 3.2)),("tvm", Array(8.0, 2.9, 9.1, 2.5)))) val df1= rdd.toDF("id", "vals") val rdd1 = ...

1 a resposta

Como fazer uma chamada POST para servidor autocertificado com akka-http

Eu tenho uma topologia akka-streams, onde faço uma chamada POST usando akka-http. Estou recebendo o seguinte erro ao acessar a solicitação de postagem em um servidor não seguro (com certs autoassinados). É um servidor interno, então estou bem do ...

4 a resposta

Scala: produzindo os resultados intermediários de uma dobra

Eu me deparei com o problema de manter um estado durante uma operação de mapa várias vezes. Imagine a seguinte tarefa: Dada uma lista [Int], mapeie cada elemento para a soma de todos os elementos anteriores e de si mesmo. Então 1,2,3 se torna 1, ...

2 a resposta

Causado por: java.lang.NullPointerException at org.apache.spark.sql.Dataset

Abaixo eu forneço meu código. Eu itero sobre o DataFrameprodRows e para cadaproduct_PK Encontro uma sub-lista correspondente de product_PKs deprodRows. numRecProducts = 10 var listOfProducts: Map[Long,Array[(Long, Int)]] = ...

5 a resposta

Por que nenhuma matriz imutável na biblioteca padrão da scala?

Scala tem todo tipo de seqüências imutáveis como List, Vector, etc. Fiquei surpreso ao encontrar nenhuma implementação de sequência indexada imutável, apoiada por uma matriz simples (o vetor parece muito complicado para ...

3 a resposta

É aplicar e cancelar a aplicação de um construtor no scala

Em Java, podemos criar um construtor usando o nome da classe. Mas em scala eu tenho visto diferentes usos de aplicar e não aplicar. É o mesmo que o uso de um construtor em Java, no qual podemos usar aplicar e cancelar a aplicação como construtor?

1 a resposta

Como usar o s3 com o Apache spark 2.2 no shell Spark

Estou tentando carregar dados de um bucket do Amazon AWS S3, enquanto estiver no shell Spark. Consultei os seguintes recursos: Analisando arquivos do Amazon S3 com Apache ...

1 a resposta

Scala cria grupo de elementos

Eu quero criar um grupo de elementos em uma mensagem como na imagem abaixo [/imgs/n0ROx.gif] Atualizada: case class Element(key:String;value:String)A mensagem pode ser representada algo como abaixo case class ...

0 a resposta

Por que certas projeções de tipo são rejeitadas e ligeiramente diferentes, não?

Desculpe pelo título não descritivo. A computação em nível de tipo não é um tema muito comum na internet para estabelecer termos precisos. Tentei usar cálculos de nível de tipo e de repente obter erros espúrios aqui e ali. Eu simplesmente não ...