Resultados de la búsqueda a petición "scala"
No coinciden los tipos en Scala para la comprensión
¿Por qué esta construcción causa un error de tipo desajuste en Scala? for (first <- Some(1); second <- List(1,2,3)) yield (first,second) <console>:6: error: type mismatch; found : List[(Int, Int)] required: Option[?] for (first <- Some(1); ...
¿Por qué el filtro tiene que definirse para la coincidencia de patrones en un bucle for en scala?
Para crear una nueva clase que pueda usarse en una Scala para la comprensión, parece que todo lo que tiene que hacer es definir una función de mapa: scala> class C[T](items: T*) { | def map[U](f: (T) => U) = this.items.map(f) | } defined class C ...
Parámetro de conversión de Scala Akka HTTP como java.time.ZonedDateTime
Estoy trabajando en un servicio REST usando Akka HTTP (en Scala). Me gustaría que un parámetro que se pasa a una solicitud de obtención de http se convierta al tipo ZonedDateTime. El código funciona bien si intento usar String o Int pero falla ...
¿Por qué las llamadas de caché tardan tanto en un conjunto de datos de Spark?
Estoy cargando grandes conjuntos de datos y luego los almacena en caché como referencia en todo mi código. El código se parece a esto: val conversations = sqlContext.read .format("com.databricks.spark.redshift") .option("url", jdbcUrl) ...
¿Cómo puedo ver el contenido de una solicitud MultipartForm?
Estoy usando Apache HTTPClient 4. Estoy haciendo cosas multiparte muy normales como esta: val entity = new MultipartEntity(HttpMultipartMode.BROWSER_COMPATIBLE); entity.addPart("filename", new FileBody(new ...
Tramas de datos de chispa (scala): compruebe si las cadenas de la columna contienen elementos de un conjunto
Soy bastante nuevo en scala y spark y he estado tratando de encontrar una solución para este problema todo el día, me está haciendo la cabeza. He probado 20 variaciones diferentes del siguiente código y sigo obteniendotype mismatch errores cuando ...
¿Es posible pasar "esto" como parámetro implícito en Scala?
Supongamos que quiero ajustar el código que puede lanzar excepciones con un bloque try-catch que registra la excepción y continúa. Algo como: loggingExceptions { // something dangerous }Idealmente, me gustaría usar para registrar el registrador ...
No se puede resolver la columna (nombre de columna numérico) en Spark Dataframe
Esta es mi información: scala> data.printSchema root |-- 1.0: string (nullable = true) |-- 2.0: string (nullable = true) |-- 3.0: string (nullable = true)Esto no funciona :( scala> ...
¿Cómo usar Scala's this typing, abstract types, etc. para implementar un Self type?
No pude encontrar la respuesta a esto en ninguna otra pregunta. Supongamos que tengo una superclase abstracta Abstract0 con dos subclases, Concrete1 y Concrete1. Quiero poder definir en Abstract0 algo como def setOption(...): Self = {...}donde ...
¿Cómo manejar filas de líneas múltiples en spark?
Tengo un marco de datos que tiene algunas observaciones de varias líneas: +--------------------+----------------+ | col1| col2| +--------------------+----------------+ |something1 |somethingelse1 | |something2 |somethingelse2 | |something3 ...