Resultados de la búsqueda a petición "scala"
Streaming en slick / scala
Estoy viendo la transmisión scala / slick, y estoy tratando de entender cómo funciona. Aquí está mi código de prueba val bigdata = TableQuery[BigData] val x = db.stream(bigdata.result.transactionally.withStatementParameters(fetchSize ...
¿Cómo agregar un Spark Dataframe al final de otro dataframe?
Puedo usarwithcolumnpara agregar nuevas columnas a un marco de datos. Pero en scala, ¿cómo puedo agregar nuevas filas a un DataFrame? Estoy tratando de agregar un marco de datos en la parte inferior de otro. Entonces, ya sea cómo agregar filas ...
Multiplicación matricial en Apache Spark [cerrado]
Estoy tratando de realizar una multiplicación de matrices usando Apache Spark y Java. Tengo 2 preguntas principales: ¿Cómo crear RDD que pueda representar una matriz en Apache Spark?¿Cómo multiplicar dos de estos RDD?
Derivar instancias de clase de tipo para clases de caso con exactamente un campo
Estoy trabajando en una biblioteca de análisis CSV (tabular [http://nrinaudo.github.io/tabulate/]) Utiliza clases de tipo simples para codificar / decodificar: la codificación, por ejemplo, se realiza con instancias deCellEncoder (para codificar ...
Scala forma segura de convertir String a valor de enumeración
Supongamos que tengo una enumeración: object WeekDay extends Enumeration { type WeekDay = Value val Mon, Tue, Wed, Thu, Fri, Sat, Sun = Value }Me gustaría poder convertir String a valor WeekDay y esto está bien con: scala> ...
obtener TopN de todos los grupos después del grupo utilizando Spark DataFrame
Tengo un Spark SQL DataFrame: user1 item1 rating1 user1 item2 rating2 user1 item3 rating3 user2 item1 rating4 ...Cómo agrupar por usuario y luego regresarTopN artículos de todos los grupos que usan Scala? Código de similitud con ...
Hoja de trabajo de Intellij y clases definidas en ella
Estoy siguiendo el curso Coursera sobre programación funcional en Scala y encontré un comportamiento extraño de la respuesta de la hoja de trabajo. En el curso, una hoja de trabajo con el siguiente código debe dar los siguientes resultados a la ...
Clasificación explícita en la transformación cartesiana en Scala Spark
Estoy usando la transformación cartesiana en Spark Scala. Si mi entrada consta de 4 elementos (podrían ser números / caracteres / tupla), diga var myRDD=sc.parallelize(Array("e1","e2","e3","e4"))myRDD.cartesian (myRDD) produciría todas las ...
¿Cuál es la diferencia entre el enrutador inyectado de dependencia y el enrutador estático en ScalaRouting de Play Framework?
¿Cuál es la diferencia entre el enrutador inyectado de dependencia y el enrutador estático en ScalaRouting of Play Framework? La documentación del marco de Play dirige la dependencia del enrutador inyectado que se usa cuando se crea una nueva ...
¿Reformar un constructor de clase de caso?
Tratando de encontrar una manera de "remodelar" un constructor de casos para llenar algún valor predeterminado. ¿Es posible lo siguiente? def reshape[T, R1 <: HList, R2 <: HList](h: R1): R2 => T = ??? //example case class MyClass(a: Double, b: ...