Resultados de la búsqueda a petición "scala"
Scala - Spark In Dataframe recupera, para fila, nombre de columna con valor máximo
Tengo un DataFrame: name column1 column2 column3 column4 first 2 1 2.1 5.4 test 1.5 0.5 0.9 3.7 choose 7 2.9 9.1 2.5Quiero un nuevo marco de datos con una columna con contener, el nombre de la columna con tiene un valor máximo para la fila: | ...
La mejor práctica para usar constantes en anotaciones de escala
Utilizo el tapiz 5 como mi elección de marco web. Tapestry me permite definir símbolos en la clase configure e inyectar símbolos en otros componentes. por ejemplo, public interface SymbolConstants { static String DEFAULT_TIMEOUT_KEY ...
¿Por qué los objetos singleton están más orientados a objetos?
EnProgramación en Scala: una guía completa paso a paso [https://rads.stackoverflow.com/amzn/click/com/0981531644], el autor dijo: Una forma en que Scala está más orientado a objetos que Java es que las clases en Scala no pueden tener miembros ...
¿Por qué falla la unión con "java.util.concurrent.TimeoutException: Futures expiró después de [300 segundos]"?
Estoy usando Spark 1.5. Tengo dos marcos de datos de la forma: scala> libriFirstTable50Plus3DF res1: org.apache.spark.sql.DataFrame = [basket_id: string, family_id: int] scala> linkPersonItemLessThan500DF res2: org.apache.spark.sql.DataFrame = ...
Descarte de particiones de DataFrame vacías en Apache Spark
Intento repartir un DataFrame de acuerdo con una columna que tiene el DataFrameN (DigamosN=3) diferentes valores en la columna de particiónx, p.ej: val myDF = sc.parallelize(Seq(1,1,2,2,3,3)).toDF("x") // create dummy dataLo que me gusta lograr ...
¿Usar Opcional en las clases de caso de Scala y los campos de clases es un olor a código?
Ya hubo bastantes discusiones sobre Stackoverflow sobre formas adecuadas de usarOpcional en Java (discusiones comoéste [https://stackoverflow.com/questions/31922866/why-should-java-8s-optional-not-be-used-in-arguments] , o ...
Cómo convertir Row a json en Spark 2 Scala
¿Hay una manera simple de convertir un objeto Row dado a json? Encontré esto acerca de convertir un Dataframe completo a salida json:Spark Row a JSON [https://stackoverflow.com/questions/36157810/spark-row-to-json] Pero solo quiero convertir ...
¿Por qué esta línea Scala devuelve una Unidad?
Aquí hay un poco de código Scala para sumar los valores del 1 al 9 que son divisibles por 3 o 5. ¿Por qué la línea 5 devuelve una Unidad y no un tipo booleano? object Sample { def main(args : Array[String]) { val answer = (1 ...
InheritableThreadLocal valor no heredado por los hilos ExecutorService
import java.util.concurrent.Executors import scala.concurrent.{ExecutionContext, Future} object TestInheritableThreadLocal { def main(args: Array[String]): Unit = { implicit val ec = ExecutionContext.fromExecutor(Executors.newFixedThreadPool(2)) ...
¿Programación orientada a objetos en un contexto de programación puramente funcional?
¿Hay alguna ventaja de usar la programación orientada a objetos (OOP) en un contexto de programación funcional (FP)? he estado usandoF# [http://en.wikipedia.org/wiki/F_Sharp_%28programming_language%29]desde hace algún tiempo, y noté que cuanto ...