Resultados de la búsqueda a petición "scala"
¿Es una colección con flatMap una mónada?
Scala tiene el rasgoIterable[A] eso define def flatMap[B](f: (A) ⇒ GenTraversableOnce[B]): Iterable[B]Eso ciertamentese ve como la función de enlace en una mónada, y la documentación sugiere que es una mónada, pero hay dos objeciones, una menor ...
¿Scala ofrece IO sin bloqueo asíncrono cuando trabaja con archivos?
Estoy usando scala 2.10 y me pregunto si hay algún paquete que tenga IO asíncrono cuando trabajo con archivos. Hice un poco de búsqueda sobre este tema, pero encontré ejemplos como los siguientes val file = new File(canonicalFilename) val bw = ...
excepción de lanzamiento de código scala en chispa
Soy nuevo en scala y spark. Hoy traté de escribir algo de código y dejé que se ejecutara por chispa, pero obtuve una excepción. este código funciona en scala local import org.apache.commons.lang.time.StopWatch ...
Spark: cómo ejecutar el archivo spark desde spark shell
Estoy usando CDH 5.2. Puedo usarchispapara ejecutar los comandos ¿Cómo puedo ejecutar el archivo (file.spark) que contiene comandos de chispa?¿Hay alguna forma de ejecutar / compilar los programas scala en CDH 5.2 sin sbt?Gracias por adelantado
Funciones sin argumentos, con unidad como argumento en scala
def foo(x:Int, f:Unit=>Int) = println(f()) foo(2, {Unit => 3+4} //case1 def loop:Int = 7 foo(2, loop) //does not compile changing loop to //case 2 def loop():Int = 7 foo(2, loop) // does not compile changing loop to //case 3 def loop(x:Unit): ...
¿Cómo probar los métodos que devuelven el futuro?
Me gustaría probar un método que devuelve unFuture. Mis intentos fueron los siguientes: import org.specs2.mutable.Specification import scala.concurrent.ExecutionContext.Implicits.global import scala.util.{Failure, Success} class ...
¿Cómo utilizar las secuencias reactivas para el procesamiento binario NIO?
¿Hay algunos ejemplos de código de usoorg.reactivestreams [http://www.reactive-streams.org/]bibliotecas para procesar grandes flujos de datos utilizando Java NIO (para un alto rendimiento)? Mi objetivo es el procesamiento distribuido, por lo que ...
Cómo crear un objeto singleton en Scala con parámetros de tiempo de ejecución
Estoy tratando de crear un objeto singleton con parámetros que se especifican en tiempo de ejecución. Ejemplo: object NetworkPusher { val networkAdress = ??? ... }Imagine que el parámetro networkAdress proviene de la línea de comandos. ¿Alguien ...
Manejo de dobles en ScalaTest
Acabo de comenzar a usar ScalaTest y estoy usando lo siguiente para comparar dos Dobles en mi especificación de la siguiente manera: it should "calculate the price" in { val x = new X(10,10,12,1000) assert(x.price() === 185.92) }La ...
SparkSQL MissingRequirementError al registrar la tabla
Soy un novato en Scala y Apache Spark y estoy tratando de usar Spark SQL. Después de clonar elrepo [https://github.com/apache/spark]Comencé la chispa escribiendobin/spark-shell y ejecuta lo siguiente: val sqlContext = new ...