Resultados de la búsqueda a petición "scala"

1 la respuesta

Cómo programar un trabajo de cuarzo con Scala

Estoy tratando de obtener el ejemplo más simple de un trabajo de cuarzo en Scala. configure () se ejecuta una vez cuando se carga mi módulo. lazy val quartz = StdSchedulerFactory.getDefaultScheduler override def configure() = { val Job = new ...

2 la respuesta

¿Podemos tener una matriz de funciones de parámetros por nombre?

En Scala tenemos parámetros por nombre donde podemos escribir def foo[T](f: => T):T = { f // invokes f } // use as: foo(println("hello"))Ahora quiero hacer lo mismo con una variedad de métodos, es decir, quiero usarlos como: def foo[T](f:Array[ ...

1 la respuesta

Scala: deslizamiento (N, N) vs agrupado (N)

Últimamente me encontré usando el deslizamiento (n, n) cuando necesito iterar colecciones en grupos de n elementos sin volver a procesar ninguno de ellos. Me preguntaba si sería más correcto iterar esas colecciones usando grouped (n). Mi pregunta ...

4 la respuesta

Cómo comprimir dos (o más) DataFrame en Spark

tengo dosDataFrame a yb. a es como Column 1 | Column 2 abc | 123 cde | 23b es como Column 1 1 2Quiero zipa yb (o incluso más) DataFrames que se convierte en algo así como: Column 1 | Column 2 | Column 3 abc | 123 | 1 cde | 23 | 2¿Cómo puedo ...

2 la respuesta

Aplanar filas en chispa

Estoy haciendo algunas pruebas de chispa usando scala. Por lo general, leemos archivos json que deben manipularse como en el siguiente ejemplo: test.json: {"a":1,"b":[2,3]} val test = sqlContext.read.json("test.json")¿Cómo puedo convertirlo al ...

1 la respuesta

Partición Spark: mucho más lenta que sin ella

Probé escribiendo con: df.write.partitionBy("id", "name") .mode(SaveMode.Append) .parquet(filePath)Sin embargo, si dejo de lado la partición: df.write .mode(SaveMode.Append) .parquet(filePath)Se ejecuta 100x (!) Más rápido. ¿Es normal que la ...

3 la respuesta

¿El mapa no puede ser serializable en scala?

Soy nuevo en Scala. ¿Cómo es que la función "mapa" no es serializable? ¿Cómo hacerlo serializable? Por ejemplo, si mi código es el siguiente: val data = sc.parallelize(List(1,4,3,5,2,3,5)) def myfunc(iter: Iterator[Int]) : Iterator[Int] = { val ...

1 la respuesta

Play Framework 2.4 utiliza la variable inyectada en la plantilla Scala

Me gustaría mostrar algunos datos de la base de datos en la barra de menú de mi página web. Para obtener los datos, tengo un objeto de acceso a datos (DAO) que generalmente se crea con la inyección de Guice. ¿Cómo puedo usar un objeto ...

1 la respuesta

¿Qué hace el signo de dólar en scala?

Cuando estaba leyendo el código fuente de chispaaquí [https://github.com/apache/spark/blob/098be27ad53c485ee2fc7f5871c47f899020e87b/mllib/src/main/scala/org/apache/spark/ml/classification/MultilayerPerceptronClassifier.scala#L66] Vi código ...

1 la respuesta

¿Qué está tratando de decirme Scala y cómo puedo solucionarlo? [requerido: java.util.List [? 0] donde escribe? 0]

Estoy en el proceso de aprender Scala y hoy me sentí seguro de presentarlo a uno de nuestros proyectos. La aplicación hace muchas cosas JPA / Hibernate y comencé a implementar una de las interfaces Java en Scala. Todo salió bien, hasta que ...