Resultados de la búsqueda a petición "scala"
Sugerencia de parámetro de desactivación de Intellij durante la escritura
No puedo entender cómo deshabilitar la sugerencia de parámetro emergente durante la escritura. Intenté desactivar la sugerencia de parámetro en la configuración de "Mostrar sugerencias de nombre de parámetro", pero no creo que eso afecte ...
¿Cómo ejecutar el script Scala usando spark-submit (de manera similar al script Python)?
Intento ejecutar un script Scala simple usando Spark como se describe en el Tutorial de inicio rápido de Spark [https://spark.apache.org/docs/1.2.0/quick-start.html]. No tengo problemas para ejecutar el siguiente código de ...
Cómo escribir ElasticsearchSink para la transmisión estructurada de Spark
Estoy usando la transmisión estructurada de Spark para procesar datos de alto volumen de la cola de Kafka y estoy haciendo algunos cálculos de ML, pero necesito escribir el resultado en Elasticsearch. Traté de usar elForeachWriter pero no puedo ...
Agregue la columna Número de días a la Columna Fecha en el mismo marco de datos para la aplicación Spark Scala
tengo undataframe df decolumns ("id", "current_date", "days") y estoy tratando de agregar el "days" a "current_date"y crear un nuevodataframe con nuevocolumn llamado "new_date"usando la función spark scaladate_add() val newDF = ...
Uso de def, val y var en scala
class Person(val name:String,var age:Int ) def person = new Person("Kumar",12) person.age = 20 println(person.age)Estas líneas de salidas de código12, aunqueperson.age=20 fue ejecutado con éxito. Descubrí que esto sucede porque usé def endef ...
¿Cómo usar DataFrame withColumn y no cambiar la partición?
Por alguna razón tengo que convertirRDD aDataFrameentonces haz algo conDataFrame. Mi interfaz esRDDasí que tengo que convertirDataFrame aRDD， Y cuando usodf.withcolumn, la partición cambia a 1, así que tengo querepartition ysortBy RDD. ¿Hay ...
Cómo abrir una conexión TCP con TLS en scala usando akka
Quiero escribir un cliente Scala que hable un protocolo propietario sobre una conexión TCP con TLS. Básicamente, quiero reescribir el siguiente código de Node.js en Scala: var conn_options = { host: endpoint, port: port }; tlsSocket ...
Anulación de operadores aritméticos en Int a través de conversiones implícitas
Digamos que, por razones estéticas, quiero poder escribir: 3 / 4y tener / ser un método en una clase que existe una conversión implícita de Int a, por ejemplo: class Foo(val i: Int) { def /(that: Int) = // something } implicit def intToFoo(i: ...
NullPointerException después de extraer una tabla Teradata con Scala / Spark
Necesito extraer una tabla de Teradata (acceso de solo lectura) al parquet con Scala (2.11) / Spark (2.1.0). Estoy construyendo un marco de datos que puedo cargar con éxito val df = spark.read.format("jdbc").options(options).load()Perodf.show me ...
Scala: ¿Por qué no podemos hacer super.val?
Estoy practicando este código de JavaTpoint para aprender herencia en Scala. Pero no puedo acceder a la bicicleta miembro de la clase Vehículo cuyo valor se inicializa a cero. Intenté por referencia de tipo súper pero todavía muestra el valor ...