Resultados de la búsqueda a petición "scala"
no se puede encontrar el resultado del método en TableQuery con slick 3.0.0-RC1
Estoy probando Slick3.0.0-RC1 y me encuentro con un problema extraño. Tal es mi código: import slick.driver.SQLiteDriver.api._ import scala.concurrent.ExecutionContext.Implicits.global import scala.concurrent.Await import ...
¿Cómo se escribe el teorema de Pitágoras en Scala?
El cuadrado de la hipotenusa de un triángulo rectángulo es igual a la suma de los cuadrados en los otros dos lados. Este es el teorema de Pitágoras. Una función para calcular la hipotenusa en función de la longitud "a" y "b" de sus lados ...
Función Scala List para agrupar elementos idénticos consecutivos
Dado por ejemplo: List(5, 2, 3, 3, 3, 5, 5, 3, 3, 2, 2, 2)Me gustaría llegar a: List(List(5), List(2), List(3, 3, 3), List(5, 5), List(3, 3), List(2, 2, 2)) Supongo que hay una función de Lista simple que hace esto, pero no puedo encontrarla.
udf No TypeTag disponible para type string
No entiendo un comportamiento de chispa. Creo un udf que devuelve un entero como a continuación import org.apache.spark.sql.SQLContext import org.apache.spark.{SparkConf, SparkContext} object Show { def main(args: Array[String]): Unit = { ...
Cómo componer el nombre de la columna usando el valor de otra columna para withColumn en Scala Spark
Estoy tratando de agregar una nueva columna a unDataFrame. El valor de esta columna es el valor de otra columna cuyo nombre depende de otras columnas de la misma.DataFrame. Por ejemplo, dado esto: +---+---+----+----+ | A| B| A_1| B_2| ...
Calcule la mediana de hasta 5 en Scala
Entonces, mientras respondía alguna otra pregunta, me topé con la necesidad de calcular la mediana de 5. Ahora, hay unapregunta similar [https://stackoverflow.com/questions/480960/code-to-calculate-median-of-five-in-c] en otro idioma, pero quiero ...
¿Cuándo necesita Scala tipos de parámetros para funciones anónimas y ampliadas?
¿Cuándo necesita realmente el compilador Scala la información de tipo de parámetros de funciones anónimas? Por ejemplo, dada esta función: def callOn[T,R](target: T, f: (T => R)) = f(target)entonces no puedo usarlo así: callOn(4, _.toString) ...
Spark / scala crea un conjunto de datos vacío utilizando genéricos en un rasgo
Tengo un rasgo llamado que toma un parámetro de tipo, y uno de sus métodos debe ser capaz de crear un conjunto de datos con tipo vacío. trait MyTrait[T] { val sparkSession: SparkSession val spark = sparkSession.session val sparkContext = ...
Cómo usar destinos de texto io de flujo de datos dinámicos en java
Hola, estoy muy confundido por la API de destinos de archivos dinámicos y no hay documentos, así que aquí estoy. La situación es que tengo una PCollection y contiene eventos que pertenecen a diferentes particiones. Quiero dividirlos y ...
Spark Dataframe - Función de ventana - Retraso y adelanto para salida de inserción y actualización
Necesito realizar la siguiente operación en marcos de datos usando la función de ventana Lag y Lead. Para cada clave, necesito realizar la inserción y actualización a continuación en la salida final Insertar condición: 1. Por defecto, LAYER_NO ...