Я пытаюсь прочитать сообщение от Кафки.Сообщение в следующем формате (пример):...
У меня есть фрейм данных, в котором есть два столбца, был создан импорт файла .txt. пример...
Я пытаюсь получить процент записей со значением выше 2. Вот код: val seq = Seq(0, 1, 2, 3) val...
Скажем, у меня есть выражение, дерево которого я хочу записать (не оценивая его!), А затем передать...
У меня есть данные за 3 года, разделенные на year / month / day / hour Я хочу прочитать все файлы,...
Резюме: Мы обновили несколько файлов JS для внешнего интерфейса.Эти изменения включают в себя...
Мне нужно создать схему, используя существующее поле df. Рассмотрим пример этого кадра данных...
Моя искровая работа - чтение с кафки и расшифровка сообщения.моя искровая работа хорошо работает на...
Я пытаюсь удалить несколько столбцов из кадра данных.Я последовал примеру на https://stackoverflow
Я использую следующий код для загрузки данных из Кассандры: val ts = spark .read .format("org
У меня есть CSV-файл с событиями согласно таблице ниже. +-------------------+-------+ |Created...
У меня очень простая работа Spark, которая пишет в S3. В таблице есть 3 разных ключа...
У меня есть данный фрейм данных, как показано ниже...
Я использую play-json_2.11 и пытаюсь рекурсивно анализировать некоторые классы дел sealed trait...
В API Apache Spark я могу использовать функцию startsWith для проверки значения столбца:...
Следующий синтаксис: def func0(x: Int => Int, y: Int)(in: DataFrame): DataFrame = { in
Я обнаружил, что при работе с SortedMap и TreeMap могут возникать различные рабочие характеристики...
Я бы хотел обновить кластеры Kafka моей команды с версии 0.10.1.1 до версии 2.1.0. Кстати, в...
У меня есть фрейм данных, у меня есть список значений (возможно, строка списка), и я хочу создать...
У меня есть базовый класс с двумя конструкторами и дочерний класс, который имеет один конструктор....
Я создал два массива, используя кадры данных, как показано ниже. Array1: val df1 = hc
Я новичок в Scala и читал о частично примененных функциях в Scala. У меня есть общая функция "wrap"...
Мы планируем использовать Drools в нашей организации с Scala / Spark.Мы выбрали Drools версии 5.3.0...
у меня следующий набор данных: col1_id, col2_id, type 1 t1_1 t1 1 t1_2 t1 2 t2_2 t2 col1_id &...
Я пытаюсь перезаписать один раздел, используя приведенный ниже код, но вместо перезаписи / замены...