Resultados de la búsqueda a petición "scala"
Agregando una columna de conteo a mi secuencia en Scala
Dado el siguiente código, ¿cómo haría para agregar una columna de conteo? (por ejemplo, .count ("*"). as ("count")) Salida final para parecerse a esto: +---+------+------+-----------------------------+------ | id|sum(d)|max(b)|concat_ws(,, ...
Error al intentar hacer que un actor persistente requiera un buzón personalizado con RequiereMessageQueue
Intento lo siguiente: class ClientActor (stockActor: ActorSelection, paymentsActor: ActorSelection) extends PersistentActor with AtLeastOnceDelivery with akka.actor.ActorLogging with RequiresMessageQueue[akka.custom.CustomMailbox]{ //actor ...
¿Cómo ordenar DataFrame con mi comparador usando Scala?
Me gustaría ordenar un DataFrame basado en una columna con mi propio comparador. ¿Es posible hacer esto en Spark SQL? Por ejemplo, supongamos que tengo un DataFrame registrado como Tabla "MyTable" con una columna "Day" cuyo tipo es ...
Esquema generado dinámicamente en un archivo json para un archivo de datos csv en scala
Necesita su ayuda para definir un esquema dinámico con campos y tipos de datos del archivo JSon de metadatos de entrada para los datos en un archivo csv en Databricks. Quiero definir un esquema que asigne el nombre del campo con el tipo de ...
¿Cómo usar Scala Cats Validado de la manera correcta?
Siguiendo es mi caso de uso Estoy usando Gatos [https://typelevel.org/cats/] para la validación de mi configuración. Mi archivo de configuración está en json. Deserializo mi archivo de configuración a mi clase de casoConfig utilizando ...
Cómo convertir una cadena de fecha y hora a larga (UNIX Epoch Time) en Java 8 (Scala)
Quiero el Tiempo de Época UNIX (Tiempo Posix, Tiempo Unix) de una cadena en algunapattern, la cadena está en formato normal (por lo tanto, UTC). Utilice Java 8, no Joda o Java antiguo. (Para milisegundos, consulte Cómo convertir una cadena de ...
Zeppeling lanzando NullPointerException mientras configura
Estoy tratando de configurar zeppelin-0.8.0 en mi sistema operativo windos 8 r2. Ya he ejecutado spark en mi consola, es decir, SPARK_HOME y JAVA_HOME, HADOOP_HOME configurado y funcionando bien. Pero mientras intento ejecutar printl ("hola") en ...
Por qué IntelliJ no ejecuta mi script si tiene main en él
Estoy observando un comportamiento interesante. Tengo un proyecto existente en el que creé una carpeta y creé unaScala script en esa carpeta. Para ejecutarlo hice Escribe un script Scala, p. MyScript.scala En el menú, seleccione: Ejecutar ...
Kafka consumidor no devuelve ningún evento
El consumidor de Scala kafka a continuación no devuelve ningún evento depoll llamada Sin embargo, el tema es correcto, y puedo ver los eventos que se envían al tema utilizando el consumidor de la ...
Spark Funciones de ventana que dependen de sí mismo
Digo que tengo una columna de marcas de tiempo ordenadas en un DataFrame. Quiero escribir una función que agregue una columna a este DataFrame que corte las marcas de tiempo en segmentos de tiempo secuenciales de acuerdo con las siguientes ...