Resultados de la búsqueda a petición "scala"
¿Cómo puedo actualizar una variable de transmisión en la transmisión por chispa?
Tengo, creo, un caso de uso relativamente común para la transmisión por chispa: Tengo una secuencia de objetos que me gustaría filtrar en función de algunos datos de referencia Inicialmente, pensé que esto sería algo muy simple de lograr usando ...
generador de datos aleatorios de clase de caso scalacheck
Estoy tratando de generar datos aleatorios con Scalacheck. Tengo una jerarquía de clases de casos con muchas propiedades. La única forma que he encontrado hasta ahora para llenar las clases de casos es así: case class Data(a: String, b: String, ...
Reemplazar valores nulos en Spark DataFrame
Vi una solución aquí, pero cuando lo intenté no me funciona. Primero importo un archivo cars.csv: val df = sqlContext.read .format("com.databricks.spark.csv") .option("header", "true") .load("/usr/local/spark/cars.csv")Que se parece a lo ...
¿Cómo agregar un directorio personalizado al proyecto Scala SBT?
Tenemosconf directorio en nuestro proyecto que está bien, pero uno de los nuevos componentes requiere que se coloque su propia configuración enconfig directorio y no podemos cambiar ese requisito. En mi build.scala agregué la ...
¡Cómo aplicar evoluciones manualmente en pruebas con Slick and Play! 2,4
Me gustaría ejecutar manualmente mi script de evolución al comienzo de cada archivo de prueba. Estoy trabajando con Play! 2.4 y Slick 3. Según la documentación, el camino a seguir parece ser: Evolutions.applyEvolutions(database)pero no logro ...
Lista de carpetas de Spark Scala en el directorio
Quiero enumerar todas las carpetas dentro de un directorio hdfs usando Scala / Spark. En Hadoop puedo hacer esto usando el comando:hadoop fs -ls hdfs://sandbox.hortonworks.com/demo/ Lo probé con: val conf = new Configuration() val fs = ...
Implementación de Akka-Stream más lenta que la implementación de subproceso único
ACTUALIZACIÓN DE 2015-10-30 basado en Roland Kuhn Awnser: Akka Streams está utilizando mensajes asíncronos que pasan entre actores para implementar etapas de procesamiento de flujo. El paso de datos a través de un límite asincrónico tiene una ...
Genéricos Scala: ¿Cómo declarar que un tipo debe ser una clase de caso?
Tengo varias clases de casos con uncount campo. Es 1 por defecto, y tengo una reducción en mi código que agrupa duplicados y suma ese valor para encontrar el número de cada objeto. P.ej.: case class Person(name: String, count = ...
Usando diferentes mónadas en la comprensión
¿Se pueden usar diferentes mónadas para comprender? Aquí está el código que usamap case class Post(id: Int, text: String) object PostOps { def find(id: Int) : Option[Post] = if (id == 1) Some(Post(1, "text")) else None def permitted(post: Post, ...
¿Cómo puedo omitir los campos de clase de caso en una asignación de tabla pulida?
Me estoy enseñando algo de Scala y actualmente me estoy mojando los pies con slick (3.1) + play framework, así que tal vez la respuesta sea simple aquí y me falta algo obvio. Tengo el siguiente modelo y tabla case class User(id: Long = -1, ...