Resultados de la búsqueda a petición "scala"
En Scala, ¿qué es un "inicializador temprano"?
En Martin Odersky'spublicación reciente sobre los niveles de habilidad del programador [http://www.scala-lang.org/node/8610]en Scala, en elDiseñador experto en bibliotecas sección, incluye el término"inicializadores tempranos". Estos no se ...
Scala agrega una nueva columna al marco de datos por expresión
Voy a agregar una nueva columna a un marco de datos con expresión. por ejemplo, tengo un marco de datos de +-----+----------+----------+-----+ | C1 | C2 | C3 |C4 | +-----+----------+----------+-----+ |steak|1 |1 | 150| |steak|2 |2 | 180| ...
Obtener el tamaño / longitud de una columna de matriz
Soy nuevo en la programación de Scala y esta es mi pregunta: ¿Cómo contar el número de cadenas para cada fila? Mi Dataframe se compone de una sola columna de tipo Array [String]. friendsDF: org.apache.spark.sql.DataFrame = [friends: array<string>]
Instalación de sbt en Windows 10 para el curso Scala
Las instrucciones para el curso dicen usar la versión 0.13.x. Instalé el último msi del sitio sbt, pero cuando escribo "sbt about", obtengo: Microsoft Windows [Version 10.0.15063] (c) 2017 Microsoft Corporation. All rights reserved. ...
¿Cómo crear un conjunto de datos de mapas?
Estoy usando Spark 2.2 y estoy teniendo problemas al intentar llamarspark.createDataset en unSeq deMap. El código y la salida de mi sesión de Spark Shell siguen: // createDataSet on Seq[T] where T = Int works scala> ...
¿Cómo puede leer dataframereader http?
Mi entorno de desarrollo: IntellijMavenScala2.10.6win7 x64Dependencias: <dependencies> <!-- https://mvnrepository.com/artifact/org.apache.spark/spark-core_2.10 --> <dependency> ...
Cómo usar Scalatest para desarrollar un compilador-complemento en Scala
De hecho, estoy desarrollando un complemento compilador para Scala de acuerdo con el artículo sobrehttp://www.scala-lang.org/node/140 [http://www.scala-lang.org/node/140]. Aquí está el código del complemento: package localhost import ...
¿Cómo funciona akka stream throttle?
def throttle(elements: Int, per: FiniteDuration, maximumBurst: Int, mode: ThrottleMode): Repr[Out]HacemaximumBurst significa la cantidad de elementos que se pueden procesar al mismo tiempo?
¿Una manera fácil de deshacerse de * todo * generado por SBT?
¿Hay una manera fácil de deshacerse de todo lo que se genera como resultado de realizar una compilación SBT? Resulta que crea directorios de destino en todo el lugar. Ejecutando sbt clean clean-cache clean-lib clean-plugins... no se deshace de todo.
¿Cómo leo un archivo CSV grande con la clase Scala Stream?
¿Cómo leo un archivo CSV grande (> 1 Gb) con Scala Stream? ¿Tienes un ejemplo de código? ¿O usaría una forma diferente de leer un archivo CSV grande sin cargarlo primero en la memoria?