Resultados de la búsqueda a petición "scala"
Filtro de chispa DataFrame en cadena contiene
estoy usandoSpark 1.3.0 [http://spark.apache.org/releases/spark-release-1-3-0.html]ySpark Avro 1.0.0 [https://github.com/databricks/spark-avro/tree/c5612df9b1a9768689fec91655faa2a7073fd9fc#spark-sql-avro-library] . Estoy trabajando desdeel ...
Objeto scala burlón
Estoy usando mockito e intento burlarme de un objeto scala. object Sample { } //test class SomeTest extends Specification with ScalaTest with Mockito { "mocking should succeed" in { val mockedSample = mock[Sample] } } Esto me da dos errores de ...
¿Cómo funciona el manifiesto de Scala (2.8)?
Tengo un código Scala que hace un uso bastante intensivo de los genéricos, y he deducido de los documentos que el uso de un manifiesto en las restricciones de parametrización puede ayudarme a solucionar los problemas de borrado de tipo (por ...
¿Cómo evitar que Intellij cree carpetas src / main / java y src / main / scala-x?
Tengo un proyecto SBT en Intellij 15.0.2 para programación solo de escala. Por alguna razón, el proyecto sigue creando las siguientes carpetas en mi proyecto: src / main / javasrc / main / scala-2.10src / main / scala-2.11src / prueba / javasrc ...
Futuro de Akka: ¿paralelo o concurrente?
De lo bien escritoConcurrencia Akka [http://www.artima.com/shop/akka_concurrency]: [/imgs/xFnqg.png] Comoentiendo, el diagrama señala, ambosnumSummer ycharConcat correrá en el mismo hilo. ¿Es posible ejecutar cadaFuture en paralelo, es decir, ...
Tener una lista en los parámetros del servicio web marco de juego
He escrito este servicio web en el marco de juego. controlador def getByGenre(genre: String) = Action { val result = Await.result(Movies.getByGenre(genre), 5 seconds) Ok(toJson(result)) }rutas GET /movies/genre/:genre ...
SQLContext implicits
Estoy aprendiendo chispa y scala. Estoy bien versado en Java, pero no tanto en Scala. Estoy revisando un tutorial sobre spark, y encontré la siguiente línea de código, que no se ha explicado: val sqlContext = new ...
Hacer que las características de los datos de prueba sean iguales a los datos del tren después de la selección de características en chispa
Estoy trabajando en Scala. Tengo una gran pregunta, ChiSqSelector parece reducir la dimensión con éxito, pero no puedo identificar qué características se redujeron y qué quedaron. ¿Cómo puedo saber qué funciones se redujeron? [WrappedArray(a, b, ...
¿Cómo detecto si un Spark DataFrame tiene una columna?
Cuando creo unDataFrame desde un archivo JSON en Spark SQL, ¿cómo puedo saber si existe una columna determinada antes de llamar.select Ejemplo de esquema JSON: { "a": { "b": 1, "c": 2 } }Esto es lo que quiero hacer: potential_columns = ...
Trabajo Spark con llamada HTTP asíncrona
Construyo un RDD a partir de una lista de URL, y luego trato de obtener datos con alguna llamada http asíncrona. Necesito todos los resultados antes de hacer otros cálculos. Idealmente, necesito hacer las llamadas http en diferentes nodos para ...