Resultados de la búsqueda a petición "scala"
¿Por qué es flatMap en un Vector [Opción [Int]] cuyo resultado de la función del mapeador no es un Vector [Opción [Int]] válido?
Por ejemplo, Vector(Some(1), Some(2), Some(3), None).flatMap{ n => n }produce unVector(1, 2, 3) en lugar de dar un error Como he visto en otros idiomas,flatMap se usa cuando tiene una función de mapeador que produce anidamiento, por lo que ...
Spark: aborde comandos intensivos de rendimiento como collect (), groupByKey (), reduceByKey ()
Sé que algunas de las acciones de Spark comocollect() Causar problemas de rendimiento. Ha sido citado endocumentación [http://spark.apache.org/docs/latest/programming-guide.html#transformations] Para imprimir todos los elementos en el ...
Cómo convertir una cadena JSON a un documento BSON
Tengo la siguiente función que usa el controlador reactivemongo y realmente hace un buen trabajo escribiendo en la base de datos. def writeDocument() = { val document = BSONDocument( "firstName" -> "Stephane", "lastName" -> "Godbillon", "age" -> ...
ListSet ordenado por inserción
ListSet (collection.immutable.ListSet) es un conjunto ordenado inverso. Necesito conjunto ordenado. Este es un ejemplo del ListSet original: var a = ListSet(1,2,3) var ite = a.iterator ite.next // returns 3 ite.next // returns 2 ite.next // ...
¿Cómo acceder a Play Framework 2.4 guice Injector en la aplicación?
Quiero usar elgetInstance método del GuiceInjector clase en Play Framework 2.4, ¿cómo puedo acceder a ella? He usado el GuiceFactoryModuleBuilder para implementar una fábrica que devuelve otra fábrica en tiempo de ejecución! En el segundo nivel ...
HList sin forma a TupleN donde la forma de tupla no necesita coincidir exactamente con la forma HList
Me gustaría crear el equivalente de: def toTupleN[A1, ..., AN, L <: HList](l: L): TupleN[A1, ..., AN]Código usandotoTupleN debe compilarse solo cuando hay exactamente unoN combinación de valores enl a partir de la cual se podría crear la tupla. ...
¿Cómo usar sincronizado en Scala?
Tengo el siguiente código: object Foo { private var ctr = 0L def bar = { ctr = ctr + 1 // do something with ctr } }El requisito es que unctr el valor debe usarse solo una vez. En mi caso, el mismo valor dectr se está reutilizando Mi teoría es ...
Problemas de confiabilidad con Checkpointing / WAL en Spark Streaming 1.6.0
DescripciónTenemos una aplicación Spark Streaming 1.5.2 en Scala que lee eventos JSON de un Kinesis Stream, realiza algunas transformaciones / agregaciones y escribe los resultados en diferentes prefijos S3. El intervalo de lote actual es de 60 ...
Descubrir la cadena de invocaciones implícitas
¿Hay alguna manera de averiguar la cadena implícita completa (y estoy interesado en todos los tipos implícitos)? Estoy usando IntelliJ Idea, pero estoy buscando cualquier forma de hacerlo, incluso si tengo que trabajar con otro IDE. (y ...
¿Cómo puedo revertir una prueba de integración con Slick 3 + Specs2?
Quiero escribir algunas pruebas de integración para un servicio que se ejecuta de manera ingeniosa y luego limpiar una base de datos postgresql luego de una transacción, pero no veo la manera de hacerlo. Entiendo que puedo probar objetos DBIO que ...