Я выполняю проверку xsd и пытаюсь получить имя текущего узла при возникновении исключения, но я...
У меня огромный текстовый файл (в ГБ) с плановыми текстовыми данными в каждой строке, который...
Мы можем прочитать файл avro, используя следующий код, val df = spark.read.format("com
Я должен сгенерировать, где условие основано на классе дела / фрейме данных. Например, у меня будут...
У меня есть фрейм данных, к которому я присоединился с устаревшими данными и обновленными данными:...
В принципе, у меня есть DataFrame, который состоит из "Имя" и "Значения" полей. Первое поле -...
Моя база данных имеет значение numeric, которое составляет до 256-битного целого числа без знака....
Я немного застрял, пытаясь конвертировать RDD[Array[Byte]] в Array[Byte]. У меня есть следующее,...
У меня есть сценарий использования, где схемой столбца является String, но на самом деле это json...
После вызова "spark-submit" нормально работает в оболочке /bin/bash -c '/local/spark-2.3
Я использую Spark версии 2.2.0 и scala версии 2.11.8. Я создал и сохранил модель двоичной...
Я пытаюсь сохранить коллекцию ссылок на объекты Spark для данных в фрейме, чтобы позже я мог...
Я очень новичок в Скале. Я работал с PySpark ранее. Я попытался запустить spark shell с кодом ниже,...
Ниже приведен код, в котором я пытаюсь динамически загрузить таблицу в Hbase, но я получаю...
Я работаю над сценарием, где мне нужно иметь вложенные циклы. Я могу получить желаемый результат,...
Есть класс: public class DeserializerHelper<T> extends AbstractSchemaHelper { public...
У меня проблема с разбиением столбца метки времени на столбцы даты и времени. Сначала время не...
У меня есть две таблицы в Улей - emp(empid int,empname string,deptid string) dept(deptid string,...
У меня есть данные, как показано ниже, и я хочу уменьшить их, комбинируя соседние строки, т.е....
У меня есть файл json, который содержит объекты json, каждый объект за строкой. У меня есть...
Как я могу внести изменения в интернационализацию JS-файла для предупреждения, не передавая...
Как прочитать данные в теме кафки в СДР, указав начальное и конечное смещения? KafkaUtils.createRDD...
Я пытаюсь создать внешнюю таблицу для чтения данных из многораздельных паркетных файлов в формате...
Я пытаюсь сохранить данные в файл avro, используя spark в scala, но получаю значение ниже Exception...
Я использую версию spark-sql_2.11-2.3.1 с Cassandra 3.x. Мне нужно предоставить функцию проверки,...