Resultados de la búsqueda a petición "scala"
¿Cómo realizar la coincidencia de patrones con clases de casos vararg?
Tengo un conjunto de clases de casos como este abstract class Shape case class Rectangle(width: Int, height: Int) extends Shape case class Location(x: Int, y: Int, shape: Shape) extends Shape case class Circle(radius: Int) extends Shape case ...
Usando futuros en los actores de Akka
Estoy empezando a aprender Akka Actors en Scala. Tengo entendido que los mensajes recibidos por un actor se ponen en cola en el buzón de un actor y se procesan uno por uno. Al procesar los mensajes uno a la vez, se mitigan los problemas de ...
¿Es posible instalar una devolución de llamada después de que el procesamiento de la solicitud haya finalizado en Spray?
Estoy tratando de servir archivos temporales grandes de Spray. Necesito eliminar esos archivos una vez que se complete la solicitud HTTP. No pude encontrar una manera de hacer esto hasta ahora ... Estoy usando un código similar ...
¿Por qué scala.util.Failure tiene un parámetro de tipo?
scala.util.Failure se declara así: final case class Failure[+T](exception: Throwable) extends Try[T]`Toma un parámetro de tipoT que parece completamente innecesario, dado cómoFailure podría ser fácilmente declarado como un subtipo ...
unir dinámicamente dos marcos de datos de spark-scala en varias columnas sin condiciones de unión de codificación fija
Me gustaría unir dos marcos de datos de spark-scala en varias columnas dinámicamente. Evitaría la comparación del nombre de la columna de codificación rígida como se muestra en las siguientes declaraciones; val joinRes = df1.join(df2, ...
Manera simple de aplicar una lista de funciones a un valor
Supongamos que tengo una lista de funcionesList[A => B] y necesita una función que regreseList[B] para un valor dado de tipoA: def foo[A, B](fs: List[A => B]): A => List[B] = a => fs.map(_.apply(a))¿Hay alguna más simple (tal vez concats) forma ...
¿Cómo transformar el marco de datos en un vector de características de etiqueta?
Estoy ejecutando un módulo de regresión logística en scala y tengo un marco de datos como el siguiente: df +-----------+------------+ |x |y | +-----------+------------+ | 0| 0| | 0| 33| | 0| 58| | 0| 96| | 0| 1| | 1| 21| | 0| 10| | 0| 65| | 1| ...
¿Cómo leer registros en formato JSON de Kafka usando Structured Streaming?
Estoy tratando de usarenfoque de transmisión estructurada [http://spark.apache.org/docs/latest/structured-streaming-programming-guide.html] usando Spark-Streaming basado en DataFrame / Dataset API para cargar un flujo de datos desde Kafka. Yo ...
¿Por qué el envío arroja "java.net.ConnectException: General SSLEngine ..." y excepciones de "estado inesperado" para una URL en particular?
Tengo el siguiente código que no funciona: object Main extends App { import dispatch._ def test(address: String) = { Await.result(Http.default(url(address).GET OK as.String), Duration.Inf) } // This works fine val s1 ...
Spark divide el valor de una columna en varias filas
Mi problema es que tengo una tabla como esta: ------------------------ A B C ------------------------ a1 b2 c1|c2|c3|c4c1 | c2 | c3 | c4 es un valor separado por |. Mi resultado final debería verse así: --------- A B C --------- a1 b1 c1 a1 b1 ...