Resultados de la búsqueda a petición "scala"
Scala no puede resolver miembros constantes heredados de la interfaz Java
Jerarquía de clases en Java: Interfaz:Racimo, Clasificar ClaseKluster jerarquía se muestra a continuación Cluster <- , +-- Kluster Classify <- 'Expediente:oop / Cluster.java package oop; public interface Cluster { public String HELLO = ...
¿Cómo se define una @interface en Scala?
¿Cómo se crea un@interface en Scala? Honestamente me siento estúpido haciendo esa pregunta, pero no puedo encontrar la sintaxis para estoen cualquier sitio. Sé que puede consumirlos, pero ¿cómo define realmente otros nuevos en ...
Scala implícitamente vs argumentos implícitos
Soy nuevo en Scala, y cuando miro diferentes proyectos, veo dos estilos para tratar con argumentos implícitos. scala]]>def sum[A](xs:List[A])(implicit m:Monoid[A]): A = xs.foldLeft(m.mzero)(m.mappend) sum:[A](xs:List[A])(implicit ...
Spark UDAF con ArrayType como problemas de rendimiento de bufferSchema
Estoy trabajando en un UDAF que devuelve una variedad de elementos. La entrada para cada actualización es una tupla de índice y valor. Lo que hace el UDAF es sumar todos los valores bajo el mismo índice. Ejemplo: Para entrada (índice, valor): ...
¿Cómo usar las funciones collect_set y collect_list en la agregación en ventana en Spark 1.6?
En Spark 1.6.0 / Scala, ¿hay una oportunidad para obtenercollect_list("colC") ocollect_set("colC").over(Window.partitionBy("colA").orderBy("colB")?
¿Cómo crear el proyecto Spark / Scala en IntelliJ IDEA (no puede resolver las dependencias en build.sbt)?
Estoy tratando de construir y ejecutar un proyecto Scala / Spark en IntelliJ IDEA. Yo he añadidoorg.apache.spark:spark-sql_2.11:2.0.0 en bibliotecas globales y mibuild.sbt se ve a continuación. name := "test" version := "1.0" scalaVersion := ...
Leer datos de Cassandra para procesar en Flink
Tengo que procesar flujos de datos de Kafka usando Flink como motor de transmisión. Para hacer el análisis de los datos, necesito consultar algunas tablas en Cassandra. ¿Cuál es la mejor manera de hacer esto? He estado buscando ejemplos en Scala ...
Cree un mapa para llamar al POJO para cada fila de Spark Dataframe
Construí un modelo H2O en R y guardé el código POJO. Quiero puntuar archivos de parquet en hdfs usando el POJO pero no estoy seguro de cómo hacerlo. Planeo leer los archivos de parquet en chispa (scala / SparkR / PySpark) y marcarlos allí. ...
¿Cómo se usa Akka en Play?
Página de inicio de Play [http://www.playframework.com/]dice: Basado en Akka, Play proporciona un consumo de recursos predecible y mínimo (CPU, memoria, subprocesos) para aplicaciones altamente escalables. Me gustaría saber exactamente cómo y ...
¿Cómo obtengo una instancia de la clase de tipo asociada con un contexto vinculado?
Nota: estoy planteando esta pregunta para responderla yo mismo, pero otras respuestas son bienvenidas. Considere el siguiente método simple: def add[T](x: T, y: T)(implicit num: Numeric[T]) = num.plus(x,y)Puedo reescribir esto usando ...