scala — preguntas con respuestas

1 respuesta
Quiero leer muchos archivos de parquet en diferentes caminos. Primero quiero hacer una lista de cadenas que contenga todas las rutas en el formulario: \local\id_*_*\data\version.*\* ex: \local\id_231_2232318\data\version.501\part1.parquet ... \local\id_7_456\data\version.502\part1.parquet \local\i...
apache-spark-dataset
apache-spark-2.0
30 jul. 2018, в 18:28
3 respuestas
Encontré varios enfoques para encontrar la diferencia de los conjuntos de claves entre dos mapas. Sin embargo, quiero comparar la clave completa-> valores. Tengo una configuración de dos mapas como Map[String, Map[String, String]] Entonces si tengo dos mapas var source = Map( "one" -> Map(...
30 jul. 2018, в 15:36
4 respuestas
Tengo alguna función que se obtiene como entrada específica de fecha y hora de inicio y final (por ejemplo, "2018-01-01 16:00:00" y "2018-01-01 17:00:00" ) (al comienzo de el código i import java.sql.Timestamp ) Quiero repetir esta función con el tiempo (por ejemplo, entre 2018...
timestamp
loops
30 jul. 2018, в 13:30
1 respuesta
Estoy siguiendo algunos tutoriales de Spark y para mi consternación parece que el profesor no sigue las mejores prácticas de Scala. Utiliza cambios de estado y var mientras que preferiría trabajar con datos inmutables; así que cambié mi código para adaptarme mejor al paradigma funcional, sin embarg...
apache-spark
functional-programming
30 jul. 2018, в 13:14
1 respuesta
He probado soluciones, descritas en ¿Cómo anular un valor implícito? , pero no ayuda. Aquí hay un ejemplo de código. Una definición de abstracción TestImplicit con 2 implementaciones diferentes (análogo de ExecutionContextExecutor ): trait TestImplicit { def f(s:String):Unit } object TestImplici...
implicit
overrides
30 jul. 2018, в 12:07
1 respuesta
Quiero obtener la suma de un seq de Integer s en Scala. En mi mente, quiero doblar una ventaja sobre los enteros como este: val seqOfIntegers:Seq[Int] = Seq(1, 2, 3, 4, 5) val sumOfIntegers = seqOfIntegers.reduce(+) Esto no es valido. En cambio tengo que hacer: val sumOfIntegers = seqOfIntegers....
reduce
infix-operator
30 jul. 2018, в 11:42
1 respuesta
Estoy escribiendo pruebas unitarias para la implementación del modelo de actor akka. El sistema contiene clases y rasgos que deben inicializarse. Mi problema radica en la prueba de los métodos. Cuando me burlo de los parámetros requeridos para una clase, elimina el error del compilador intelij, sin...
unit-testing
mockito
akka
actor
30 jul. 2018, в 11:09
2 respuestas
Con el framework lightbend Lagom estoy tratando de conectarme a la API websocket de Binance. Sin embargo, sigo recibiendo el siguiente error al conectarme: 400 The plain HTTP request was sent to HTTPS port ¿Debería ser posible desde Lagom conectarse a un servicio websocket seguro? ¿Entonces co...
websocket
lagom
30 jul. 2018, в 10:48
1 respuesta
Recorrer y modificar un gráfico acíclico dirigido heterogéneo en Scala Buenos dias a todos. Tengo la siguiente estructura de datos de gráfico acíclico dirigida, implementada en Scala de la siguiente manera: abstract class Node // Generic abstract node /** Various kind of leaf nodes */ case class...
software-design
data-structures
recursion
directed-acyclic-graphs
30 jul. 2018, в 10:48
1 respuesta
Tengo el siguiente esquema de tabla de Cassandra: - CREATE TABLE test ( id text, stats frozen<map<text, text>> ) Creé la aplicación scala para extraer los datos de cassandra y después de alguna manipulación actualizaré nuevamente los datos a cassandra. val result = session.execute("Se...
cassandra
cassandra-3.0
30 jul. 2018, в 10:40
1 respuesta
Estoy intentando ejecutar una aplicación Scala Play y obtuve esta excepción: Caused by: com.typesafe.config.ConfigException$Missing: No configuration setting found for key 'memo' at com.typesafe.config.impl.SimpleConfig.findKeyOrNull(SimpleConfig.java:152) ~[config-1.3.1.jar:na] at com.typesafe.con...
playframework
15 jul. 2018, в 13:08
1 respuesta
Actualmente estoy trabajando en un problema que implica trabajar con palabras en inglés. Soy bastante nuevo en programación funcional y quiero escribir el mejor código posible. ¡Es una pregunta muy simple pero solo quiero hacer esto bien! ^^ ¿Como creo una estructura de datos para palabras en ingl...
data-structures
15 jul. 2018, в 12:08
1 respuesta
¿Cómo puedo realizar la operación groupBy en una Lista de clases de casos que tienen clases de casos como campos? Por ejemplo: case class F1(str1:Option[String],str2:Option[String]) case class F2(int1:Option[Int],int2:Option[Int]) case class Parent(str:F1, int:F2) Digamos que tengo una Lista de c...
dynamic
grouping
case-class
15 jul. 2018, в 11:22
1 respuesta
El siguiente código funciona @throws(classOf[IKodaMLException]) def soMergeTarget1( oldTargetIdx: Double, newTargetIdx: Double): RDDLabeledPoint = { try { logger.trace("\n\n--sparseOperationRenameTargetsInNumeriOrder--\n\n") val oldTargetIdxb=spark.sparkContext.broadcast(oldTargetI...
apache-spark
20 jun. 2018, в 01:27
1 respuesta
Estoy escribiendo un combinador de analizador para analizar declaraciones de flujo de control simples y ejecutar algún código. La estructura del lenguaje es más o menos esto: val resultId = 200 val s = s"""(IF $resultId == 100 GOTO NODE-1-->NODE-2) (ELSE IF $resultId > 100 GOTO NODE-1-->...
parser-combinators
20 jun. 2018, в 01:26
Arriba
Menu