Итак, у меня есть входные данные, которые выглядят так: HEADER_A|HEADER_B|HEADER_C|HEADER_D...

Я использую Scala отражение и набор инструментов для оценки динамической функции в виде строки.И я...

Я хочу написать функцию Scala, такую ​​как def functionA(objectMap:Map[String, ClassB], statements:...

Spark имеет множество настраиваемых параметров.Здесь я хотел бы знать, какова оптимальная...

Какая принципиальная разница с использованием .GroupByKey и .GroupBy, когда я использую имя столбца...

[New to Spark] После создания DataFrame я пытаюсь разбить его на основе столбца в DataFrame.Когда я...

Итак, у меня есть набор маршрутов Akka Http, написанных на scala.Вот как это выглядит val route:...

Я пытаюсь создать набор данных из json-строки в кадре данных в Databricks 3.5 (Spark 2.2.1).В блоке...

Стиль функционального программирования в руководстве по кодированию гласит, что мы не должны...

Я пытаюсь составить монады в Scala и выполнить несколько запросов к серверу.вот фрагмент кода,...

У меня есть СДР, как показано ниже: val rdd1 = sc.parallelize(Array((1,2),(2,3),(4,5),(5,2),(4,3)))...

Я работаю над проектом, чтобы продемонстрировать, как простой пинг-понг может работать в...

Пример (168,20874, Список (, 33895, 2711)) до 168,20874 |, 33895, 2711 В основном конвертировать...

Я новичок в Scala и мне нужна помощь, чтобы выяснить, как подсчитать вхождение значений пары ключей

Я пытаюсь автоматизировать и загружать случайные данные в пустой фрейм данных, используя spark...

Я пытаюсь обновить свое приложение с использования Play 2.3.x до Play 2.4.x (закончится на 2.6, но...

spark2-shell import org.apache.hadoop.hbase.HBaseConfiguration import org.apache.hadoop.hbase

Я пытаюсь преобразовать DStream [Array [Byte]] в DStream [String], но получаю сообщение об ошибке:...

У меня есть один фрейм данных, который имеет много столбцов почти 50 плюс (как показано ниже),...

Я получаю ошибку ниже при запуске искрового задания. Это похоже на проблему несовместимости в...

Я пытался создать базу данных с помощью следующего кода Часть моих зависимостей сборки scalaVersion...

Я выполнил запрос CREATE TABLE IF NOT EXISTS OMIDimensionshql.DimPrimaryProduct (PrimaryProductKey...

Проработанный сценарий -> каталог HDFS, который «заполняется» новыми данными журнала о нескольких...

давайте предположим, что у меня есть большая система, которая использует Scala Global Execution...

Я нашел причину, по которой мое приложение ведет себя не так, как мне хотелось бы, но я не знаю,...