Я пытаюсь загрузить данные из таблицы Excel в таблицу кустов. Выдает ошибку ниже
Я пытаюсь применить функцию к каждой строке Spark DataFrame, как в примере. val df = sc
Я читаю с URL / порта, выполняю некоторую обработку и записываю обратно на URL / порт. Url / Port...
У меня возникает следующая проблема: при печати выполненного плана я не могу просмотреть все...
У меня есть следующие настройки в build.sbt : lazy val proj = (project in file("."))
У меня есть SQL-запрос, который обновляет table как Update table set a.Column1 = b.Column1, a
Я пытаюсь сохранить информацию о значении null в столбце после применения преобразования...
Хотите преобразовать timestamp столбец в timeuuid, вот мой spark фрейм данных (импортированный...
У меня есть RDD [String] с этой формой: VAR1,VAR2,VAR3,VAR4, ... a , b , c , d , ... e , f , g , h ...
Я хочу взять данные 1000-й мс в окне за 1 секунду, нужна помощь по оконной функции. По сути, мне...
Я новичок в Apache Spark и мне нужна помощь.Может кто-нибудь сказать, как правильно объединить...
У меня есть метод, который еще предстоит определить, но тип возвращаемого значения известен. Есть...
Я пытаюсь выбрать все элементы, присутствующие в foo, но не присутствующие в баре.Я использую этот...
Я пытаюсь написать общий метод max для значений Scala Enumeration. У меня def enumMax[E <:...
У меня есть эта проблема с mapType в искре с использованием scala API для каждого сеанса. Мы...
Я пытаюсь добавить идентификатор для каждой группы дат, используя Spark Scala. Например, если ввод...
Я пытаюсь сделать API Rest с помощью Akka. Одна из точек входа вернет данные из моей базы данных...
Я читаю файл в искровом фрейме.В первом столбце я получу два значения, соединенных с "_".Мне нужно...
Я хочу упорядочить по времени некоторые авро-файлы, полученные из HDFS. Схема моих файлов avro:...
Я написал карту, как показано ниже, моя реализация mutable.HashMap. class SampleMap() extends...
Я прочитал эту статью и скопировал пример Sort-Merge Join, но когда я пытаюсь построить проект, я...
Я читаю csv-файл, используя scala для заполнения набора данных, и там я сталкиваюсь с проблемой...
Я пытаюсь добавить featureD в виде массива Double в Vectors.dense функцию, но получаю эту ошибку:...
Я пытаюсь прочитать очень большой графический файл, который имеет формат: 1 2,3 3,2,1 7,4,3 4,3,4,6...
У меня есть параллельная иерархия типов, которые в общем ссылаются друг на друга: один через...