Resultados da pesquisa a pedido "scala"
Como acessar os recursos de teste?
Eu tenho um arquivodata.xml emsrc/test/resources/. Como posso ler esse arquivo em um novoFileReader no meu testedata.scala emsrc/test/scala/?
Como chamar os construtores Option da scala de Java
Estou trabalhando em um projeto java / scala misto e estou tentando chamar o método de um objeto scala a partir de Java. Este método leva umOption[Double] como um parâmetro. Eu pensei que isso iria funcionar: Double doubleValue = new ...
Maven SBT artefatos de dependência?
Eu gerencio meu projeto usando Maven e SBT ao mesmo tempo. As razões para isso são: Intellij IDEA não pode importar o projeto SBT. (O plugin idea-sbt não funciona muito bem) Não sei como obter fontes e javadocs do SBT (gostaria de ...
park operação de quadro de dados no nível de linha e coluna usando scala
Quadro de dados original 0,2 0,3 +------+------------- -+ | name| country | +------+---------------+ |Raju |UAS | |Ram |Pak. | |null |China | |null |null | +------+--------------+ I Need this +------+--------------+ |Nwet|wet Con | ...
particionador do @Spark DataFrame é None
[Novo no Spark] Depois de criar um DataFrame, estou tentando particioná-lo com base em uma coluna no DataFrame. Quando verifico o particionador usandodata_frame.rdd.partitioner Eu receboNenhu como saída. Particionamento usando ...
InternalCompilerException: a classe de compilação foi carregada através de um carregador diferente
Estou usando o intérprete Scala para avaliar as instruções Scala, provenientes da configuraçã código da amostra é: import org.apache.spark.SparkConf import org.apache.spark.sql.{DataFrame, SparkSession} import scala.tools.nsc.Settings ...
Como chamar esses métodos de objetos em um mapa?
Problem: Eu tenho que chamar os métodos Objects que estão armazenados em um mapa, para uma determinada chave como fazê-lo?Code: trait Processor00 { def process(x:String): Unit } case class Processor20() extends Processor0 { override def ...
Como corrigir este erro "não encontrado: valor BMValsProcessor"
Como corrigir este erro neste código trait Processor00 { def process(oraOptionDfConfig: DataFrameReader, sparkSession: SparkSession ): Unit } class BMValsProcessor extends Processor { def process(oraOptionDfConfig: DataFrameReader, sparkSession: ...
Popular uma lista é Scala com duplo acaso aleatório para sempre
Sou novo no Scala e estou tentando obter uma lista de valores duplos aleatórios: O problema é que, quando tento executar isso, leva muito tempo em comparação com o seu homólogo Java. Alguma idéia de por que isso é ou uma sugestão sobre uma ...
Produto cumulativo no Spark?
Tento implementar um produto cumulativo no Spark scala, mas realmente não sei como fazê-lo. Eu tenho o seguinte quadro de dados: Input data: +--+--+--------+----+ |A |B | date | val| +--+--+--------+----+ |rr|gg|20171103| 2 | |hh|jj|20171103| 3 ...