Я хочу иметь возможность отображать в журнале, кто вызвал ошибку: def printError(errorMessage:...

Сохранение DataFrame в таблицу со столбцами VARBINARY вызывает ошибку: com.microsoft.sqlserver.jdbc

У меня есть RDD, в котором данные имеют форму (x, y), ExampleObject Итак, класс имеет 2 переменные:...

Как показано ниже в дампе потока, поток с идентификатором qtp336276309-556300 получил org.apache

Я хотел написать выходной файл в виде паркета.Для этого я преобразовал RDD в набор данных,...

Я пытаюсь жестко закодировать определенные строки в формат даты и времени. val cst= ZoneId

Мне нужно создать несколько файлов JSON на основе комбинаций строк. Например, в приведенной ниже...

я получил 1 сообщение в кафке, состоящее из нескольких независимых строк json.я хочу передать это...

Я новичок в Play Framework. Я пытался добавить библиотеки Spark и Kafka в build.sbt, но получаю эту...

Я не знаю, что именно произошло, но с сегодняшнего дня я борюсь за создание пакета maven. У меня...

Пожалуйста, дайте мне знать, как создать файл .tsv в коде блоков данных (scala, python). ex: Пример...

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

встретили некоторую путаницу по поводу фильтра.Существует RDD val имен слов следующим образом:...

Я планирую использовать Apache Zeppelin с Postgresql 9.5.Мой SQL-запрос и данные ниже.Я хочу, чтобы...

У меня есть фрейм данных. Я сгруппировал фрейм данных, используя следующий код. val w = Window

В моем Spark DataFrame есть столбец StructType, который я хочу разбить на несколько столбцов. case...

Проблема: При попытке чтения файлов HDF5 в Spark с помощью H5spark java.io.IOException: unexpected...

У меня есть следующий код (Java с Spark SQL) - import static org.apache.spark.sql.functions.col; ..

Я прорабатываю главу 9 «Функциональное программирование в Scala» (книга Мэннинга Пола Кьюзано и...

Пытаясь устранить неполадки при сборке sbt, хотелось бы узнать, какой шаблон в sbt.repositories...

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

Я пытаюсь преобразовать столбец набора данных в истинный возраст.Я использую Scala со Spark, и мой...

Я использую Spark локально на моем Mac.Моя версия 2.2.1, и я пытаюсь воспроизвести пример...

Я пытаюсь отфильтровать этот текстовый файл...

Я занимаюсь разработкой приложения с использованием Scala и Slick.У меня есть таблица с именем...