Preguntas con Tag: scala

Scala es un lenguaje de programación de uso general dirigido principalmente a la máquina virtual de Java. Diseñado para expresar patrones de programación comunes de una manera concisa, elegante y de tipo seguro, se fusiona ambos ...

¿Cómo aislar particiones basadas en una columna?

Estoy buscando realizar un trabajo aislado dentro de una sola partición de un marco de datos Spark. Quiero iterar sobre filas dentro de una sola partición sin ningún otro contenido de partición int
scala apache-spark partition
byteexplorer
3 años, 4 meses, 6 días

¿Cómo lanzar una excepción cuando su método devuelve un futuro en una prueba?

Así que tengo un método TokenService llamado useToken: def useToken(token: String): Future[T] = { // returns either an instance of T or throws a ServerExcept
scala scalatest
algorithmadeptc6cb
3 años, 4 meses, 7 días

slick 3.3.2 no se une al escribir explícitamente una consulta

Estoy tratando de conseguir dos mesas unidas con slick 3.3.2 y jugar 2.7.x, pero me cuesta entender por qué mis códigos no hacen lo que quiero. Tengo dos mesas: Foo y Bar</
scala playframework slick
devepicenter
3 años, 4 meses, 8 días

Cómo dividir el marco de datos de chispa a la lista de datos por colis o condiciones

Tengo miles de millones de marcos de datos de filas, quiero dividir este marco de datos en cientos por valor de algunos cols de etiquetas. mis datos como este value|col1|col2|co
scala dataframe apache-spark apache-spark-sql
bitwisewizard
3 años, 4 meses, 8 días

No reiniciar la fuente de akka que se crea a partir de la respuesta Htp

He creado al cliente WS en el marco de juego2.6 que se conecta a REST API. Esta API de reposo está enviando constantemente fragmentos/stream de datos. Pero entonces durante pocos segundos el servid
scala akka-stream playframework-2.6
compilerhero
3 años, 4 meses, 4 días

Es posible cargar automáticamente un def implícito si se incluye como dependencia (sin importar)

Estoy trabajando en una biblioteca común que incluye una biblioteca de config (https://github.com/kxbmap/configs). Esta bib
scala implicit
pixelprodigy50bb
3 años, 4 meses, 6 días

Cómo resolver el error java.io. NoSerializable ¿Excepción trabajando en el marco de datos?

def URLEnc(input: String): String = { URLEncoder.encode(input, "UTF-8") } val URLEncUDF: UserDefinedFunction = udf(URLEnc(_: String)) val file = spark.read.format("xml") .optio
java scala apache-spark
csscraftsman
3 años, 4 meses, 8 días

cómo resumir dos acumuladores de salida en scala

Soy capaz de aumentar el acumulador(totalMatchedCitationsCount totalNumUnMatchedCitationsCount) pero incapaz de añadir dos productos acumuladores. val conf = new SparkConf().setAppNam
scala apache-spark
devgeek
3 años, 4 meses, 7 días

Cada caso como prueba separada en Scala Test - JUnit Parameterized Estilo de prueba

Esta es una prueba parametrizada en JUnit: @ParameterizedTest @ValueSource(strings = {"Username", "User123", "Another username", "Another_username" }) @DisplayName("should eva
scala scalatest
techtrailblazer8d2c
3 años, 4 meses, 4 días

Incapaz de ejecutar la prueba de cálculo (problema jvm)

Estoy tratando de ejecutar la prueba de cálculo en MacOS. Java versión: openjdk versión "1.8.0_275" scala version: 2.12.12 sbt versión :1.4.4 No puedo hacer mis pruebas debido a este error. H
scala sbt gatling
geekguru
3 años, 4 meses, 8 días

scala combina colecciones como colecciones 1d

Me gustaría tener funciones como el lenguaje R c función : #R print(c(c(1,2,3),2,3,c(1,2))) > c(1,2,3,2,3,1,2) mi solución es trait SeqMagn
r scala collections
debugduke
3 años, 4 meses, 5 días

Generar el rasgo derivado con los mismos métodos pero sin primer parámetro en cada método en Scala

Contexto Tengo algunas interfaces "clientes" definidas en mi aplicación de backend scala y tienen aproximadamente esta forma: trait BackendClient { def foo: FooClient } trai
scala code-generation
cyberscribe
3 años, 4 meses, 5 días

configuración de twitter finagle redis cliente con tls habilitado

¿Cómo puedo configurar el cliente de finagle Redis con tls-enabled? @Provides def providesRedisClient(@Flag("redis-addr") host: String): redis.Client = { redis.Client(host) }
scala redis twitter-finagle
cyberjedi
3 años, 4 meses, 6 días

Cómo convertir el caso a cuando de otro modo en marcos de datos de chispa

Me gustaría reescribir el código teradata para generar marcos de datos usando scala, enfrentando un error "cuando() no se puede aplicar una vez más() se aplica ", Ayuda es apreciada.
scala apache-spark apache-spark-sql teradata
pixelprodigy
3 años, 4 meses, 7 días

¿Cómo puedo entender este ejemplo de recursión en Scala?

Tengo el siguiente método en Scala que utiliza la recursión: def foldLeft[Result](initial:Result, op:(Result, Elem) => Result) : Result = { if (isEmpty) initial else ta
scala recursion
binarybuilder
3 años, 4 meses, 8 días

Aggregation after sort(), persist() and limit() in Spark

Estoy tratando de conseguir la suma de una columna de la parte superior n filas en un DataFrame persistido. Por alguna razón, lo siguiente no funciona: val df = df0.sort(col(
scala apache-spark apache-spark-sql
nodenomad
3 años, 4 meses, 7 días

Ejecutando múltiples Insertar declaraciones en un lote usando sqlu en Slick(Scala)

Actualmente tengo lo siguiente y donde cada registro individual se ejecuta uno a la vez. private var db: Option[DatabaseDef] = .... typedRecords.foreach(publishToDatabase(_)) def pub
scala slick
codejuggernaut
3 años, 4 meses, 6 días

Crear archivo csv en Scala

Estoy tratando de crear un csv archivo en Scala obteniendo datos en forma de JsValue de una tercera parte API. Mi método para guardar datos al archivo CSV es: def saveToC
json scala opencsv
debugdynamo46a0
3 años, 4 meses, 8 días

Instrumentación para contar cada declaración en una función Scala

Tengo un simple Scala función en la que quiero aumentar una variable de clase cada vez que se ejecuta una declaración. class C { var cnt: Int: 0
scala instrumentation bytecode-manipulation byteman
coderconqueror
3 años, 4 meses, 8 días

Big Query Estado de trabajo hecho antes de que termine la consulta

Tengo una aplicación scala que crea una tabla tsv usando BigQuery. Cuando un usuario intenta acceder a los datos que quiero devolverlo si el trabajo de consulta está terminado, de lo contrario dile
scala google-cloud-platform google-bigquery cats-effect
quantumcoder403a
3 años, 4 meses, 8 días

¿Por qué mi conector Alpakka SFTP nunca se conecta?

Soy nuevo en Alpakka/Akka Streams y estoy tratando de configurar un flujo donde transmito datos entre dos servidores SFTP con mi sistema en el centro, aquí está el código. import akka
scala akka akka-stream alpakka
coderconqueror
3 años, 4 meses, 7 días

Cómo convertir un clásico ActorContext a uno tipo

Digamos que defino algunos mensajes: sealed trait Command case class A(i: Int) extends Command case class B(str: String) extends Command Y luego un actor clásico como
scala akka akka-actor akka-typed
techinnovator
3 años, 4 meses, 8 días

Usando 'esto' en la definición de clase Scala anidada

Tengo la siguiente clase abstracta con el método :: y la clase interna ListNode abstract class SimpleList[+Elem] { def head: Elem def tail: SimpleList[Elem] def isEmpty: Boolean
scala oop
binarybard
3 años, 4 meses, 7 días

Variable de sesión de acceso desde otro escenario

Me estoy quedando atrapado en este escenario. Por ejemplo, tengo 3 escenarios A, B y C. El scn A generará un valor necesario para B y C. So scn B y C será ejecutado en paralelo pero después de que
gatling scala-gatling
algoarchitect
3 años, 4 meses, 7 días

Scala Compiler Plugin Rewrite Función Definición Como Tuple: error: no se encuentra: valor scala. Tuple2

Estoy escribiendo un plugin compilador para reescribir una definición de función como un tuple de la función hash + cuerpo de función Así que lo siguiente def f(a: Int, b: Int)
scala scalac
byteexplorer
3 años, 4 meses, 5 días

Spark Scala - Winsorize DataFrame columns within groups

Estoy preprocesando datos para entradas de aprendizaje automático, una columna de valor objetivo, llámalo "precio" tiene muchos outliers, y en lugar de winsorizing precio sobre todo el conjunto Qui
scala apache-spark statistics data-science
quantumcoder403a
3 años, 4 meses, 7 días

Mockito error cuando intenta burlarse de gatos.effect.IO

Estoy tratando de burlarme cats.effect.IO por val ioSql: IO[Sql[IO, SqlConnection[IO]]] = mock[IO[Sql[IO, SqlConnection[IO]]]] Sql y Sq
scala mockito cats-effect
csscraftsman
3 años, 4 meses, 6 días

¿Cómo se puede utilizar ScalaTest en un archivo de prueba Java?

Es posible utilizar ScalaTest en un archivo de prueba Java, y si es así, ¿dónde puedo encontrar ejemplos? Cuando intento algo como: // MyU
java scala scalatest
quantumcoderd26d
3 años, 4 meses, 8 días

¿Cómo puedo crear subtipos de Int en Scala?

¿Cómo puedo crear varios tipos que son esencialmente Ints, es decir, puede obtener el valor int, puede utilizar operadores de matemáticas como + BUT donde las instancias de diferentes tipos no pued
scala types functional-programming
techtrailblazer
3 años, 4 meses, 7 días

escala - no puede resolver el símbolo:

Soy nuevo en Scala y tengo alguna pregunta sobre por qué string::List() obras List()::s ¿No? También quiero saber si ListBuffer funciona mejor que ::?<pre
list scala
pixelpilot
3 años, 4 meses, 6 días

Excepción de tiempo de ejecución java.lang.NoSuchMethodError: com.google.common.base.Optional.toJavaUtil()L con conector Spark-BigQuery

Actualmente estoy tratando de conectarme a BigQuery desde Spark. He construido un archivo de frasco de grasa usando sbt assembly plugin e intentar lanzar el trabajo en modo local utili
scala apache-spark google-bigquery sbt-assembly
cybermage
3 años, 4 meses, 5 días

¿Cómo configurar correctamente HTTPS de cadena de certificados, certificado y clave privada? Akka HTTP

Intro Tengo que programar un microservicio usando Akka HTTP. [Done] El servicio tiene que funcionar dentro de un contenedor de muelles. [Done] La comunicación (a través
scala ssl https openssl akka-http
quantumquill
3 años, 4 meses, 8 días

Convertir objeto JSON en Lista seleccionada

Quiero convertir el objeto JSON en otro formato. Mi objeto JSON parece. { "schema": [ { "name": "cust_id", "
arrays json scala
bytebarricade
3 años, 4 meses, 6 días

Más una lista vinculada: Enfoque funcional

He estado golpeando mi cabeza en este problema de código de leet. Me pregunto si hay una manera funcional de abordar esto. Todo lo que puedo inventar es usar objetos mutables (en Scala). Dado
scala functional-programming
algorithmarchitect
3 años, 4 meses, 6 días