Resultados de la búsqueda a petición "scala"
Eliminar tablas temporales de Apache SQL Spark
yo tengoregistertemptable enApache Spark utilizandoZeppelin abajo: val hvacText = sc.textFile("...") case class Hvac(date: String, time: String, targettemp: Integer, actualtemp: Integer, buildingID: String) val hvac = hvacText.map(s => ...
¿Cómo puedo obtener objetos Function a partir de métodos en Scala?
Supongamos que tengo una clase simple en Scala: class Simple { def doit(a: String): Int = 42 }¿Cómo puedo almacenar en un val la Function2 [Simple, String, Int] que toma dos argumentos (el objeto Simple de destino, el argumento String) y puede ...
Girar un cubo en opengl moderno ... se ve extraño
Estoy algo perdido, realmente perdido. Estoy tratando de rotar un cubo (justo alrededor del eje y por ahora) y este es el resultado (feo e incorrecto): [/imgs/F95ZB.gif] Este es el código para rotar la matriz: def rotate(axis: Vector3, ...
Cómo escribir en HDFS usando Scala
Estoy aprendiendo Scala y necesito escribir un archivo personalizado en HDFS. Tengo mi propio HDFS ejecutándose en una imagen de Cloudera usando vmware fusion en mi computadora portátil. Este es mi código real: package org.glassfish.samples ...
La diferencia entre countDistinct y distinct.count
¿Por qué obtengo diferentes salidas para..agg(countDistinct("member_id") as "count") y..distinct.count? ¿Es la diferencia la misma que entreselect count(distinct member_id) yselect distinct count(member_id)?
Lectura de Cassandra usando Spark Streaming
Tengo un problema cuando uso la transmisión por chispa para leer de ...
¿Por qué el ciclo de transmisiones de Akka no termina en este gráfico?
Me gustaría crear un gráfico que se repita n veces antes de hundirse. Acabo de crear esta muestra que cumple mis requisitos, pero no termina después de hundirse y realmente no entiendo por qué. ¿Alguien puede iluminarme? Gracias. import ...
¿Cómo se registran las solicitudes de un cliente HTTP de Akka?
Necesito registrar las solicitudes de clientes http akka, así como sus respuestas. Si bien parece haber un indicio de API para registrar estas solicitudes, no existe una documentación clara sobre cómo debe hacerse. Mi enfoque ha sido crear una ...
akka-http: Cómo configurar encabezados de respuesta
Tengo una ruta de la siguiente manera: val route = { logRequestResult("user-service") { pathPrefix("user") { get { respondWithHeader(RawHeader("Content-Type", "application/json")) { parameters("firstName".?, "lastName".?).as(Name) { name => ...
Rendimiento de chispa para Scala vs Python
Prefiero Python sobre Scala. Pero, como Spark está escrito de forma nativa en Scala, esperaba que mi código se ejecute más rápido en Scala que en la versión de Python por razones obvias. Con esa suposición, pensé en aprender y escribir la ...