Resultados de la búsqueda a petición "scala"
¿Puede un autoescala Scala imponer un tipo de clase de caso
¿Habría alguna forma en scala para definir el tipo propio de un rasgo como una clase de caso, como en "cualquier clase de caso"? Me gustaría que un tipo automático pueda usar el.copy método de una clase de caso, haciendo cumplir que su auto tipo ...
Usando groupBy en Spark y volviendo a un DataFrame
Tengo dificultades cuando trabajo con marcos de datos en chispa con Scala. Si tengo un marco de datos que deseo extraer una columna de entradas únicas, cuando usogroupBy No me devuelven un marco de datos. Por ejemplo, tengo unDataFrame llamados ...
Rango de cálculo de una fila
Quiero clasificar la identificación del usuario en función de un campo. Para el mismo valor del campo, el rango debe ser el mismo. Esa información está en la tabla Hive. p.ej. user value a 5 b 10 c 5 d 6 Rank a - 1 c - 1 d - 3 b - 4¿Cómo puedo ...
Cómo usar las nuevas anotaciones anidadas de Scala 2.8.0
parece que cuando está fuera de escala scala 2.8.0, podemos usar anotaciones anidadas en nuestras capas de persistencia. ¿Pero cómo? ¿Alguien puede transformar esto de Java a Scala? Gracias. @NamedQueries({ @NamedQuery(name = "findAll", ...
Spark 1.5.1, Cassandra Connector 1.5.0-M2, Cassandra 2.1, Scala 2.10, NoSuchMethodError dependencia de guayaba
Nuevo en el entorno de Spark (y bastante nuevo en Maven), por lo que me cuesta cómo enviar las dependencias que necesito correctamente. Parece que Spark 1.5.1 tiene una dependencia guava-14.0.1 que intenta usar y se agregó isPrimitive en 15+. ...
¿Cómo puedes heredar un método genérico de fábrica?
Supongamos que tiene una clase Persona y cree una clase de colección extendiéndola, p. ArrayBuffer: class Persons extends ArrayBuffer[Person] { // methods operation on the collection }Ahora, con ArrayBuffer, puede crear una colección con el ...
Cliente Akka TCP: ¿Cómo puedo enviar un mensaje a través de TCP usando akka actor?
Quiero enviar mensajes de texto a través de TCP. Muy fácil. Quiero hacerlo con akka. Leí este artículo sobre akka IO: http://doc.akka.io/docs/akka/snapshot/scala/io-tcp.html [http://doc.akka.io/docs/akka/snapshot/scala/io-tcp.html] El artículo ...
Tarea SBT sourceGenerators: ejecutar solo si un archivo cambia
En mi proyecto SBT, tengo un archivo de entradasrc/main/greeting/Greeting.txt con el siguiente contenido: Hello, world!Este es mibuild.sbt que genera la fuente Scala a partir deGreeting.txt archivo: sourceGenerators in Compile += Def.task{ ...
Spark, Scala, DataFrame: crea vectores de características
tengo unDataFrame que se parece a seguir: userID, category, frequency 1,cat1,1 1,cat2,3 1,cat9,5 2,cat4,6 2,cat9,2 2,cat10,1 3,cat1,5 3,cat7,16 3,cat8,2El número de categorías distintas es 10, y me gustaría crear un vector de características ...
¿Cómo definir una función de agregación personalizada para sumar una columna de vectores?
Tengo un DataFrame de dos columnas,ID de tipoInt yVec de tipoVector (org.apache.spark.mllib.linalg.Vector) El DataFrame tiene el siguiente aspecto: ID,Vec 1,[0,0,5] 1,[4,0,1] 1,[1,2,1] 2,[7,5,0] 2,[3,3,4] 3,[0,8,1] 3,[0,0,1] 3,[7,7,7] ....Me ...