Resultados de la búsqueda a petición "scala"
¿Cómo convertir RDD [GenericRecord] a dataframe en scala?
Recibo tweets del tema kafka con Avro (serializador y deserializador). Luego creo un consumidor de chispas que extrae tweets en Dstream de RDD [GenericRecord]. Ahora quiero convertir cada rdd en un marco de datos para analizar estos tweets a ...
Error: scalac: mala referencia simbólica. Una firma en SQLContext.class se refiere al tipo Logging en el paquete org.apache.spark que no está disponible
Cuando cumplí con un archivo scala utilizado IntelliJ IDEA, se mostró el siguiente error. Error: scalac: mala referencia simbólica. Una firma en SQLContext.class se refiere al tipo Logging en el paquete org.apache.spark que no está ...
Websocket Proxy usando Play 2.6 y transmisiones de akka
Estoy tratando de crear un Proxy simple para conexiones Websocket usando Play y akka streams. El flujo de tráfico es así: (Client) request -> -> request (Server) Proxy (Client) response <- <- response (Server)Se me ocurrió el siguiente código ...
¿Cómo el código de byte generado por scala elimina la excepción marcada?
Si es posible escribir código de bytes para un método que se supone que arroja una excepción marcada? Por ejemplo, la siguiente clase Java no se compila a menos que el método declare que arroja la excepción marcada: public class ...
scala curry por funciones anidadas o por múltiples listas de parámetros
En Scala, puedo definir una función con dos listas de parámetros. def myAdd(x :Int)(y :Int) = x + yEsto facilita la definición de una función parcialmente aplicada. val plusFive = myAdd(5) _Pero, puedo lograr algo similar definiendo ...
¿Qué decisiones de diseño favorecerían a los actores de Scala en lugar de JMS?
¿Cuáles son las diferencias usando Scala Actors en lugar de JMS? Por ejemplo, desde una perspectiva de rendimiento y escalabilidad, ¿qué agrega el modelo Scala Actor en comparación con JMS? ¿En qué casos tiene más sentido usar Actores en lugar ...
Forma óptima de crear una tubería ml en Apache Spark para el conjunto de datos con un alto número de columnas
Estoy trabajando con Spark 2.1.1 en un conjunto de datos con ~ 2000 características y estoy tratando de crear una Tubería ML básica, que consta de algunos Transformadores y un Clasificador. Supongamos, por simplicidad, que el Pipeline con el que ...
La cadena de la columna de chispa se reemplaza cuando está presente en otra columna (fila)
Me gustaría eliminar cadenas decol1 que están presentes encol2: val df = spark.createDataFrame(Seq( ("Hi I heard about Spark", "Spark"), ("I wish Java could use case classes", "Java"), ("Logistic regression models are neat", "models") ...
Scala: función promedio ponderada genérica
Quiero implementar una función de promedio ponderado genérico que relaja el requisito de que los valores y los pesos sean del mismo tipo. es decir, quiero admitir secuencias de decir:(value:Float,weight:Int) y(value:Int,weight:Float) argumentos y ...
Pregunta básica del Estado Scalaz
Como usoState para imitar el comportamiento deList.zipWithIndex? Lo que se me ocurrió hasta ahora (que no funciona) es: def numberSA[A](list : List[A]) : State[Int, List[(A, Int)]] = list match { case x :: xs => (init[Int] <* modify((_:Int) + ...