Resultados de la búsqueda a petición "scala"
java.lang.NoSuchMethodError Jackson databind y Spark
Estoy tratando de ejecutar spark-submit con Spark 1.1.0 y Jackson 2.4.4. Tengo un código scala que usa Jackson para deserializar JSON en clases de casos. Eso funciona bien por sí solo, pero cuando lo uso con chispa me sale el ...
¿Cómo manejar la excepción en la función spark map ()?
Quiero ignorar la excepción en la función map (), por ejemplo: rdd.map(_.toInt)donde rdd es unRDD[String]. pero si se encuentra con una cadena que no sea un número, fallará. ¿Cuál es la forma más fácil de ignorar cualquier Excepción e ignorar ...
UnsatisfiedLinkError: no snappyjava en java.library.path cuando se ejecuta la prueba de unidad Spark MLLib dentro de Intellij
La siguiente excepción ocurre cuando se ejecuta una prueba de unidad de chispa que requiere compresión rápida: java.lang.reflect.InvocationTargetException at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ...
Usando el resultado de Scalas "fromURL" arroja la excepción
Estoy tratando de obtener algunas páginas web usando el objeto scala.io.Source de Scala. Obtener el iterador funciona bien, pero no puedo hacer nada con él sin obtener una excepción: scala> scala.io.Source.fromURL("http://google.com") ...
Marco mínimo en Scala para colecciones con tipo de retorno heredado
Supongamos que uno quiere construir una nueva clase genérica,Novel[A]. Esta clase contendrá muchos métodos útiles, tal vez es un tipo de colección, y por lo tanto, desea subclasificarla. Pero desea que los métodos devuelvan el tipo de ...
¿Cómo imprimir elementos de una partición RDD particular en Spark?
¿Cómo imprimir los elementos de una partición particular, digamos 5to, solo? val distData = sc.parallelize(1 to 50, 10)
¿Por qué las variables anuladas obtienen valores incorrectos en Scala?
Tengo una clase A en Scala, como esta: class A { val a = 3 lazy val b = 2 println("a = " + a) println("b = " + b) }A continuación, extiendo esta clase a otra clase B: class B extends A { override val a = 4 override lazy val b = 3 }Ahora, ...
reduceByKey: ¿Cómo funciona internamente?
Soy nuevo en Spark y Scala. Estaba confundido sobre la forma en que funciona la función reduceByKey en Spark. Supongamos que tenemos el siguiente código: val lines = sc.textFile("data.txt") val pairs = lines.map(s => (s, 1)) val counts = ...
¿Por qué obtengo versiones cruzadas conflictivas en sbt en un entorno pero no en otro?
Tengo un proyecto sbt con estas dependencias: libraryDependencies ++= Seq( "org.scalatra" %% "scalatra" % ScalatraVersion, "org.scalatra" %% "scalatra-scalate" % ScalatraVersion, "org.scalatra" %% "scalatra-specs2" % ScalatraVersion % "test", ...
Usando JavaScript en la plantilla de juego
Estoy usando el juego! Marco de referencia. Y tengo un archivo de plantilla scala.html. Estoy tratando de agregar una biblioteca de JavaScript de Google para agregar gráficos a la aplicación web. Basiclly necesito poblar la siguiente función ...