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
3 años, 4 meses, 12 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
3 años, 4 meses, 13 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
3 años, 4 meses, 14 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
3 años, 4 meses, 14 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
3 años, 4 meses, 10 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
3 años, 4 meses, 12 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
3 años, 4 meses, 14 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
3 años, 4 meses, 13 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
3 años, 4 meses, 10 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
3 años, 4 meses, 13 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
3 años, 4 meses, 11 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
3 años, 4 meses, 11 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
3 años, 4 meses, 12 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
3 años, 4 meses, 13 días
¿Qué significa _ en este método que ya tiene un valor predeterminado? [duplicado]
<
scala
scala-placeholder-syntax
3 años, 4 meses, 13 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
3 años, 4 meses, 13 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
3 años, 4 meses, 13 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
3 años, 4 meses, 12 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
3 años, 4 meses, 14 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
3 años, 4 meses, 14 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
3 años, 4 meses, 14 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
3 años, 4 meses, 13 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
3 años, 4 meses, 14 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
3 años, 4 meses, 13 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
3 años, 4 meses, 13 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
3 años, 4 meses, 11 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
3 años, 4 meses, 13 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
3 años, 4 meses, 12 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
3 años, 4 meses, 14 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
3 años, 4 meses, 13 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
3 años, 4 meses, 12 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
3 años, 4 meses, 11 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
3 años, 4 meses, 14 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
3 años, 4 meses, 12 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
3 años, 4 meses, 12 días