Resultados da pesquisa a pedido "scala"
Por que ClassManifest é necessário com Array, mas não List?
Defina o seguinte código: import scala.collection.JavaConversions._ val iter:java.util.Iterator[Any] = Array[Any](1, 2, 3).iterator def func(a:Any):String = a.toString def test[T:ClassManifest](iter:java.util.Iterator[Any], func:Any=>T):Array[T] ...
Implementando um valor medido no Scala
Um valor medido consiste em número de ponto flutuante (normalmente não negativo) e unidade de medida. O objetivo é representar quantidades do mundo real e as regras que as governam. Aqui está um exemplo: scala> val oneinch = Measure(1.0, INCH) ...
Minha implementação improdutiva da projeção em perspectiva
Escrevi um programa que leva em consideração alguns pontos, expressos em coordenadas 3D e que devem ser desenhados em uma tela 2D. Eu uso projeção em perspectiva, coordenadas homogêneas e triângulos semelhantes para fazer isso. No entanto, meu ...
Como criar um conjunto de dados de mapas?
Estou usando o Spark 2.2 e estou tendo problemas ao tentar ligarspark.createDataset com umSeq doMap. Código e saída da minha sessão do Spark Shell a seguir: // createDataSet on Seq[T] where T = Int works scala> spark.createDataset(Seq(1, 2, ...
por que o filtro precisa ser definido para a correspondência de padrões em um loop for no scala?
Para criar uma nova classe que possa ser usada em um Scala para compreensão, parece que tudo que você precisa fazer é definir uma função de mapa: scala> class C[T](items: T*) { | def map[U](f: (T) => U) = this.items.map(f) | } defined class C ...
Use combineByKey para obter a saída como (key, iterable [values])
Estou tentando transformarRDD(key,value) paraRDD(key,iterable[value]), igual à saída retornada pelogroupByKey método. Mas comogroupByKey não é eficiente, estou tentando usarcombineByKey no RDD, no entanto, ele não está funcionando. Abaixo está o ...
Como usar destinos dinâmicos io de texto io de fluxo de dados em java
Olá, estou muito confuso Com a API de destinos de arquivos dinâmicos e não há documentos, então aqui estou. A situação é que eu tenho um PCollection e contém eventos pertencentes a diferentes partições. Quero dividi-los e gravá-los em diferentes ...
Nenhuma 'scala-library * .jar' em todos os novos projetos do IntelliJ Scala
Instalei o intelliJ-IDEA 2017.2.5 com o plugin scala no Ubuntu 16.04LTS. Quando crio um novo projeto scala e tento executá-lo, recebo: Erro: scalac: Não 'scala-library * .jar' no caminho de classe do compilador Scala no Scala SDK SBT: ...
Aplicar condição de filtro no quadro de dados criado a partir de JSON
Estou trabalhando no quadro de dados criado pelo JSON e quero aplicar a condição de filtro no quadro de dados. val jsonStr = """{ "metadata": [{ "key": 84896, "value": 54 },{ "key": 1234, "value": 12 }]}""" val rdd = sc.parallelize(Seq(jsonStr)) ...
Incompatibilidade de tipo (String) usando classe de caso e ator
Algum problema de formato quando estou tentando citar o código, então aqui está a imagem :( descrição da imagem aqui [https://i.stack.imgur.com/4GAYi.jpg] import akka.actor.{Actor, ActorSystem, Props} case class Number(n: Int) case class ...