Resultados de la búsqueda a petición "scala"
¿Cómo limitar el número de reintentos en la falla del trabajo de Spark?
Estamos ejecutando un trabajo de Spark a través despark-submit, y puedo ver que el trabajo se volverá a enviar en caso de falla. ¿Cómo puedo evitar que tenga el intento n. ° 2 en caso de falla del contenedor de hilo o cualquiera que sea la ...
Explica este código de coincidencia de patrón
Este código es deConsultar un conjunto de datos con la coincidencia de patrones de Scala [http://notes.langdale.com.au/Querying_a_Dataset_with_Scala_s_Pattern_Matching.html] : object & { def unapply[A](a: A) = Some((a, a)) } "Julie" match { ...
parámetros de tipo y ensanchamiento numérico
Como sabemos, podemos sumar (restar / multiplicar / etc.) dos números de diferentesNumeric tipos y el resultado será el más amplio de los dos tipos, independientemente de su orden. 33F + 9L // Float + Long == Float 33L + 9F // Long + Float == ...
Scala Random String
Espero que estés bien, acabo de comenzar la programación básica de scala, quiero generar alguna variable de cadena con foreach o algo más que creas que es el mejor método. Como usoscala.util.Random para generar este resultado: Var 1A:String = ...
Problemas al probar el ejemplo en Spark-shell
Quería probar Spark 2.0, pero cuando intenté ejecutar el siguiente código de http://spark.apache.org/docs/latest/sql-programming-guide.html#getting-started [http://spark.apache.org/docs/latest/sql-programming-guide.html#getting-started] import ...
Cómo filtrar datos usando funciones de ventana en spark
Tengo los siguientes datos: rowid uid time code 1 1 5 a 2 1 6 b 3 1 7 c 4 2 8 a 5 2 9 c 6 2 9 c 7 2 10 c 8 2 11 a 9 2 12 cAhora quería filtrar los datos de tal manera que pueda eliminar las filas 6 y 7, para un uid en particular, quiero mantener ...
Tipo de parámetro en scala
Estoy tratando de entender los conceptos de parámetros de tipo en scala. def sum [A] (a:A):A={a} // used single parameter and its working fine, able to pass any data type.Aquí: def sum[A](a:A,b:A):A={a+b} //declare two arguments <console>:7: ...
¿Podría compartir un enlace a una implementación de análisis de URL?
Por lo que entiendo, una URL consta de los siguientes campos: Protocolo (http, https, ftp, etc.)Nombre de usuarioContraseña de usuarioDirección de host (una dirección IP o un FQDN de DNS)Puerto (que puede estar implícito)Ruta a un documento ...
Scala: cómo obtener un rango de filas en un marco de datos
tengo unDataFrame creado ejecutandosqlContext.read de un archivo de parquet. losDataFrame consta de 300 M de hileras. Necesito usar estas filas como entrada para otra función, pero quiero hacerlo en lotes más pequeños para evitar errores de ...
Elija el enésimo elemento de una HList of Lists y devuelva ese valor como HList of values
Tengo una HList en la que cada columna representa una columna de una tabla. Cada lista en la HList es de la misma longitud. Me gustaría poder escribir una función que seleccione filas individuales de esta tabla como una tupla o una HList de ...