Я пытаюсь выполнить код Python внутри программы Scala. Все отлично работает локально на машине с...
Я хотел бы найти наиболее прагматичный способ принятия массива (или списка) и добавления к...
Я пытаюсь распечатать счетчик данных, а затем первые несколько строк, прежде чем окончательно...
У меня есть несколько проектов, которые не зависят друг от друга. Они совместно используют...
Я пытаюсь запустить искровой поток из очереди kafka, содержащей сообщения Avro. Согласно...
Мой build.sbt PB.targets in Compile := Seq( PB.gens.java -> (sourceManaged in Compile).value,...
Иногда я выполняю последовательность вычислений, постепенно преобразовывая какое-то значение,...
Прежде всего у меня есть фрейм данных с разными значениями: | Days | | day1 | | day2 | | day3 |...
Я использую библиотеку Cats.В Scala код выглядит следующим образом: import cats.Semigroupal import...
Мы используем кластер с открытым исходным кодом Apache spark, и у меня есть следующий...
У меня есть 2 фрейма данных: A: +----------+------+-------------+-------------+ |title |name...
Так что в основном я пытаюсь сделать калькулятор без контроля потока. У меня есть класс...
У меня работает кластер на EMR, он находится в "стартовом" шаге. Можно ли отредактировать его...
Я пытался расшифровать данные json, а затем преобразовать их в класс дел Scala с помощью GSON. Код:...
У меня есть следующий код Scala: db.run(sql""" DECLARE @Ids TABLE (ID INT NOT NULL,...
Я не могу использовать MQTTUtils.createPairedStream () в Скале? Как указать список тем в качестве...
У меня есть RDD с 3 столбцами (road_idx, snodeidx, enodeidx).Выглядит это так: (roadidx_995, 1138,...
scala> augmentedDF1.write.format("com.mongodb.spark.sql.DefaultSource")
Я пытаюсь повторно использовать RDD, который я вычисляю в одном объекте, в другом объекте.Я хочу...
По какой-то странной причине функция dayofmonth в искре, похоже, возвращает странное значение в...
У меня есть таблица со столбцом массива, например: +-Name-+ array 0:...
Вот функция: def func(map: Map[Any, Any]): String = { val mapping: Map[String, String] = map.map{...
Мне нужно пакетировать мой поток Kafka во временные окна по 10 минут каждое, а затем запустить...
Я пытаюсь понять внутренности Spark, а также плохо знаком с Scala.Я хотел бы спросить значение...
Какое значение по умолчанию для тайм-аута Ask в Akka? Все, что необходимо для использования метода...