Pytania oznaczone «scala»

9
Spark: UDF wykonywany wiele razy

Mam ramkę danych z następującym kodem: def test(lat: Double, lon: Double) = { println(s"testing ${lat / lon}") Map("one" -> "one", "two" -> "two") } val testUDF = udf(test _) df.withColumn("test", testUDF(col("lat"), col("lon"))) .withColumn("test1", col("test.one"))...

9
GRPC: tworzenie wysokowydajnego klienta w Javie / Scali

Mam usługę, która przesyła wiadomości z dość wysoką prędkością. Obecnie jest obsługiwany przez akka-tcp i wytwarza 3,5 miliona wiadomości na minutę. Postanowiłem dać grpc szansę. Niestety spowodowało to znacznie mniejszą przepustowość: ~ 500 000 wiadomości na minutę, a nawet mniej. Czy mógłbyś...