Resultados de la búsqueda a petición "scala"
Acoplar JSON en estructura tabular utilizando solo la función Spark-Scala RDD
He anidado JSON y me gusta tener salida en estructura tabular. Puedo analizar los valores JSON individualmente, pero tengo algunos problemas para tabularlo. Puedo hacerlo fácilmente a través del marco de datos. Pero quiero hacerlo usando las ...
22 Límite de columna para procedimientos
¿Cómo podemos superar el límite 22 al llamar a procedimientos con Slick? Actualmente tenemos: val q3 = sql"""call getStatements(${accountNumber})""".as[Transaction]El problema es que tenemos que devolver más de 22 columnas y la clase de ...
¿Cómo acceder a los objetos dentro de un objeto mezclando un rasgo con la reflexión?
¿Cómo puedo obtener todos los objetos dentro de un objeto con reflexión? Considera este código: object MonthDay extends MyEnum { //Some important holidays object NewYear extends MonthDay( 1, 1) object UnityDay extends MonthDay(11, 9) ...
¿Cómo agregar un método a la enumeración en Scala?
En Java podrías: public enum Enum { ONE { public String method() { return "1"; } }, TWO { public String method() { return "2"; } }, THREE { public String method() { return "3"; } }; public abstract String method(); }¿Cómo se hace esto en ...
¿Cómo leer de entrada estándar línea por línea?
¿Cuál es la receta Scala para leer línea por línea desde la entrada estándar? Algo así como el código equivalente de Java: import java.util.Scanner; public class ScannerTest { public static void main(String args[]) { Scanner sc = new ...
configurar hormiga para scala
¿Cómo instalo antlib.xml para que scala funcione correctamente? En este momento encuentro el siguiente error cuando ejecutoant en un archivo build.xml que contiene tareas scala. [taskdef] Could not load definitions from resource ...
Rellenar huecos en series temporales Spark
Tengo un problema con los datos de series temporales. Debido a fallas de alimentación faltan algunas marcas de tiempo en el conjunto de datos. Necesito llenar estos vacíos agregando filas, y después de eso, puedo interpolar los valores ...
Cómo comparar dos marcos de datos e imprimir columnas que son diferentes en escala
Tenemos dos marcos de datos aquí: el marco de datos esperado: +------+---------+--------+----------+-------+--------+ |emp_id| emp_city|emp_name| emp_phone|emp_sal|emp_site| +------+---------+--------+----------+-------+--------+ | 3| ...
Apache Spark Dataframe Groupby agg () para varias columnas
tengo unDataFrame con 3 columnas, es decirId, First Name, Last Name quiero aplicarGroupBy sobre la base deId y quiere coleccionarFirst Name, Last Name columna como lista. Ejemplo: tengo un DF como este +---+-------+--------+ |id |fName |lName ...
Scala y Spark: ¿cómo pasar por una imagen?
Tengo algunos archivos binarios que son imágenes y me gustaría revisarlos, distribuyendo los píxeles: cada nodo de mi clúster debe obtener el RGB de un grupo diferente de píxeles que los de otro nodo, y almacenar estos RGB en un Colección ...