Obtendo a instância do objeto pelo nome da string no scala

Em scala herança múltipla, como resolver métodos conflitantes com a mesma assinatura, mas diferente tipo de retorno?

Considere o código abaixo:

Cache de objeto em executores Spark

Uma boa pergunta para os especialistas do Spark. Estou processando dados em ummap operação (RDD). Dentro da função mapeador, preciso procurar objetos da classeA para ser usado no processamento de elementos em um RDD. Como isso será realizado ...

tipo genérico de retorno da função scala

Tentei escrever uma função com um tipo de retorno genérico, mas ela não funciona, a menos que eu lance o tipo de retorno. Por favor, veja a funçãogetSomething() abaixo eu esperava que funcionasse sem o casting. O que posso estar fazendo de errado ...

Por que o parâmetro de tipo vinculado T <: Comparable [T] falha em T = Int?

scala> class Foo[T <: Comparable[T]](val x : T) defined class Foo scala> (3: Int).asInstanceOf[Comparable[Int]] res60: java.lang.Comparable[Int] = 3 scala> new Foo(3) <console>:13: error: inferred type arguments [Int] do not conform to class ...

Divida 1 coluna em 3 colunas no spark scala

Eu tenho um quadro de dados no Spark usando scala que possui uma coluna que eu preciso dividir. scala> test.show +-------------+ |columnToSplit| +-------------+ | a.b.c| | d.e.f| +-------------+Eu preciso dessa coluna dividida para ficar ...

Consuma o fluxo TCP e redirecione-o para outro Sink (com Akka Streams)

Eu tento redirecionar / encaminhar um fluxo TCP para outro dissipador com o Akka 2.4.3. O programa deve abrir um soquete do servidor, ouvir as conexões de entrada e consumir o fluxo tcp. Nosso remetente não espera / aceita respostas nossas para ...

Desmistificando mitos de Scala [fechado]

Quais são os conceitos errôneos mais comuns sobre a linguagem Scala e que contra-exemplos existem para eles? ATUALIZAR Eu estava pensando mais em várias afirmações que já vi, como "Scala é digitado dinamicamente" e "Scala é uma linguagem de ...

Como obter chaves e valores da coluna MapType no SparkSQL DataFrame

Eu tenho dados em um arquivo de parquet que possui 2 campos:object_id: String ealpha: Map<>. Ele é lido em um quadro de dados no sparkSQL e o esquema se parece com o seguinte: scala> alphaDF.printSchema() root |-- object_id: string (nullable = ...

Como formatar os arquivos de compilação sbt com scalariform automaticamente?

Eu gostaria de formatar meus arquivos de compilação sbt com escalariformes. É possível executar scalariform na própria definição de compilação ao iniciar o sbt?