Resultados da pesquisa a pedido "scala"
Obter o tamanho / comprimento de uma coluna da matriz
Eu sou novo na programação Scala e esta é a minha pergunta: Como contar o número de strings para cada linha? Meu Dataframe é composto por uma única coluna do tipo Array [String]. friendsDF: org.apache.spark.sql.DataFrame = [friends: array<string>]
Como faço para tornar uma classe genérica para todos os tipos numéricos?
Estou tentando criar uma classe Vector que é genérica para todos os tipos numéricos. minha tentativa original foi escrever uma classe para todos os tipos como este: class Vector3f(val x:Float, val y:Float, val z:Float)como o scala suporta ...
Como o dataframereader pode ler http?
Meu ambiente de desenvolvimento: IntellijMavenScala2.10.6win7 x64Dependências: <dependencies> <!-- https://mvnrepository.com/artifact/org.apache.spark/spark-core_2.10 --> <dependency> ...
Como o acelerador de fluxo akka funciona?
def throttle(elements: Int, per: FiniteDuration, maximumBurst: Int, mode: ThrottleMode): Repr[Out]FazmaximumBurst significa o número de elementos que podem ser processados ao mesmo tempo?
Definindo um Mapa de String para Função no Scala
Eu estou tentando definir um literal de mapa com a chave:String, valor:(Any)=>String. Eu tentei o seguinte, mas obtive um erro de sintaxe: def foo(x: Int): String = /... def bar(x: Boolean): String = /... val m = Map[String, (Any) => ...
Como posso contar a média do Spark RDD?
Tenho um problema com o Spark Scala, que quero contar a média dos dados Rdd, crio um novo RDD como este, [(2,110),(2,130),(2,120),(3,200),(3,206),(3,206),(4,150),(4,160),(4,170)]Quero contá-los ...
Scala: Function0 vs parâmetros por nome
Alguém pode dar uma resposta definitiva sobre como parâmetros por nome=> T eFunction0 parâmetros() => T são transformados um no outro pelo compilador Scala? Eu sei que eles não são os mesmos, mas a diferença é muito sutil, pois eles podem ser ...
O equivalente 'let' de Clojure em Scala
Muitas vezes, enfrento a seguinte situação: suponha que tenho essas três funções def firstFn: Int = ... def secondFn(b: Int): Long = ... def thirdFn(x: Int, y: Long, z: Long): Long = ...e eu também tenhocalculate função. Minha primeira abordagem ...
Como monitorar continuamente um diretório usando o Spark Structured Streaming
Quero que o Spark monitore continuamente um diretório e leia os arquivos CSV usandospark.readStream assim que o arquivo aparecer nesse diretório. Não inclua uma solução de Spark Streaming. Estou procurando uma maneira de fazer isso usando o ...
Membros protegidos de outras instâncias em Scala
Eu apenas tive uma dificuldade enquanto aprendia Scala. Eu tenho uma hierarquia de herança que é essencialmente equivalente a isso: class A { protected def myMethod() = println("myMethod() from A") } class B extends A { def invokeMyMethod(a: A) ...