Resultados de la búsqueda a petición "scala"
¿Cuáles son las diferencias entre un futuro de Scala y un futuro de Java?
¿Hay alguna diferencia conceptual, funcional o mecánica entre un futuro de Scala y un futuro de Java? Conceptualmente, no puedo ver ninguna diferencia, ya que ambos tienen como objetivo proporcionar un mecanismo para el cálculo asincrónico.
Interpolación de cadenas, comillas de escape
Estoy un poco desconcertado por lo difícil que resulta ser. Ya he mirado alrededor de stackoverflow, pero ninguna solución parece funcionar bien para mí. Lo que quiero hacer: val file = checkcache(fileName) file match { case Some(_) => ...
¿Por qué la transmisión por chispa no funciona bien cuando uso la aplicación extendidas?
El primer código arroja una excepción de puntero nulo. object TryBroadcast extends App{ val conf = new SparkConf().setAppName("o_o") val sc = new SparkContext(conf) val sample = sc.parallelize(1 to 1024) val bro = sc.broadcast(6666) val ...
Directiva de separación del aerosol
Dado el siguiente código de spray: object Main extends App with SimpleRoutingApp { implicit val system = ActorSystem("my-system") val pipeline: HttpRequest => Future[String] = sendReceive ~> unmarshal[String] startServer(interface = "localhost", ...
Levante el filtro para forzar ssl
En una aplicación Struts, tengo un filtro que obliga a acceder a ciertas páginas solo a través de https a través de la redirección. Estoy pensando en portarlo para levantarlo, así que mi pregunta es: en este entorno, ¿hay una forma de "levantar" ...
¿Cómo usar Flink's KafkaSource en Scala?
Estoy tratando de ejecutar un programa de prueba simple con KafkaSource de Flink. Estoy usando lo siguiente: Flink 0.9Scala 2.10.4Kafka 0.8.2.1Seguí los documentos para probar KafkaSource (dependencia agregada, agrupar el conector Kafka ...
SparkContext no serializable dentro de un objeto complementario
Actualmente estoy tratando de extender una aplicación de Machine Learning que usa Scala y Spark. Estoy usando la estructura de un proyecto anterior de Dieterich Lawson que encontré en ...
¿Cómo configurar el directorio de caché Ivy por usuario o en todo el sistema?
estoy usandoSBT [http://www.scala-sbt.org/]como mi herramienta de construcción para construir un proyecto Scala. Mi problema es que no puedo configurar SBT para descargar dependencias en mi directorio de inicio de usuario. Por lo tanto, estoy ...
¿Cómo puedo filtrar filas en función de si el valor de una columna está en un conjunto de cadenas en un Spark DataFrame?
¿Existe una forma más elegante de filtrado basada en valores en un conjunto de cadenas? def myFilter(actions: Set[String], myDF: DataFrame): DataFrame = { val containsAction = udf((action: String) => { actions.contains(action) ...
Scala - Obtenga FXML UI-Elements
Estoy trabajando en un proyecto Scala / JavaFX con IntelliJ y un complemento para scala. La forma típica en Java para acceder a los elementos de su archivo fxml es establecer una identificación para cada elemento al que desea acceder y luego ...