Как написать фрагмент кода с ранним возвратом в scala без возвратов / разрывов? Например for i in 0

Я пытаюсь запустить простую программу подсчета слов с spark-submit и получаю исключение. Исключение...

У меня есть такая таблица: Clients City Timestamp 1 NY 0 1 WDC 10 1 NY 11 2 NY 20 2 WDC 15 В...

В нашей библиотеке есть процессоры данных (код Scala), которые используют типичный поток kafka:...

Я хочу создать локальную искровую среду в Intellij для разработки / тестирования приложения Spark,...

Я пытаюсь написать запрос агрегации mongoDB в Scala. Как мне написать Scala-код для использования...

Я хочу выполнить метод func с каждым вызовом метода, имеющим результат предыдущего и возвращающим...

У меня есть фрейм данных, который имеет два столбца с одинаковыми именами, так как первый столбец...

Я выставлю свою проблему на основе исходного кадра данных и того, которого я хочу достичь: val...

Я использую val str2 = regex.replaceAllIn(str1, "other") и мне нужно посчитать количество...

Допустим, у меня есть строки типа "9....3" и "0........3" и "......

Я пытаюсь отфильтровать фрейм данных в scala, сравнив два его столбца (в данном случае тему и...

У меня есть файл JSON с массивом имен таблиц.Я хочу прочитать, распечатать все эти элементы один за...

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

У меня есть API в Scala.Когда я хочу создать нового пользователя, мне нужны валидаторы в некоторых...

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

В Spark 1.6, в основном, я хотел бы применить разделение, а затем упорядочить, используя два...

У меня есть запрос на выборку, подобный этому SELECT distributor_id, count(*) AS total, sum(case...

Я использую аналитическое приложение spark и читаю таблицу MSSQL Server (всю таблицу) напрямую,...

Я наткнулся на эту проблему при попытке реализовать класс типа Bifunctior для карт (Bifunctor[Map[_...

Я хочу обновить элементы MutableList, который был объявлен вне цикла for, значениями из фрейма...

У меня есть фрейм данных: val df = Seq( ("q1", "a1", 0.31, "food"),...

У меня проблема с производительностью при загрузке файла размером 4 МБ в таблицу кустов с помощью...

Я пытаюсь использовать функцию row_number (), чтобы найти последнюю строку в каждом разделе в Spark...

У меня есть сценарий использования DStream, который содержит данные с несколькими уровнями...