Можно ли добавить новый столбец в существующую таблицу искр с помощью команды ALTER TABLE? var...
У меня есть данные в Кассандре (3.11.2), которые также являются моими df: Данные в Кассандре: id |...
У меня есть фрейм данных df +----------+----+----+----+---+---+----+---+---+-------+-------+ |...
Позвольте мне объяснить на примере, чего я хочу достичь. Начиная с DataFrame следующим образом: val...
Получение неправильного результата на счету. +--------+ |count(1)| +--------+ | 0| // Should not be...
Я создаю PDF с несколькими простыми таблицами. Каждая таблица содержит 1-2 ячейки: ячейка...
Я пытаюсь прочитать CSV-файл в кадре данных, используя кодировщик, но сталкиваюсь с некоторыми...
def map2(fun: Int=>Int)(a_list: List[Int]): List[Int] ={ if (a_list.isEmpty){ return List() }...
На прошлой неделе (2018/04/18) я создал дистрибутив моего проекта. Со вчерашнего дня (2018/04/23)...
Я пытаюсь разорвать строку (технически строки, переданные из столбца в кадре данных) и вернуть эти...
У меня есть сжатый файл JSON, который содержит массив JSON, что-то вроде этого:...
Я попытался сравнить cassandra save для таблицы с 30 000 записей для RDD и DataSet.Я обнаружил, что...
Я пытаюсь подключить Spark Streaming к Kafka в простом приложении. Я создал это приложение на...
Тест, использующий spark-sql, не выполнен из-за следующей ошибки: Коррелированные скалярные...
Я получаю следующую ошибку в моем Play, Silhouette, Cassandra приложении class UsersRepository...
Я недавно начал изучать scala и нашел интересное задание.Задача состоит в том, чтобы найти...
Я знаю, что есть ряд других вопросов об этой ошибке, но другие довольно ясно, почему есть ошибка. В...
Я пытаюсь выполнить простую случайную выборку с помощью Scala из существующей таблицы, содержащей...
Итак, я хочу «объединить» два массива [Int], добавив значение одного и того же индекса.Это должно...
Я просматривал некоторый код, написанный коллегой, и нашел метод, подобный этому: def writeFile(df:...
Я ищу функцию со следующей подписью: bind[A, B](f: A => Dataset[B], ds: Dataset[A]): Dataset[A]...
Я использую спарк 1.6.2. Может ли кто-нибудь предоставить мне схему для createDataFrame(rdd,schema)
При обновлении до Java 8 появляются ошибки, аналогичные приведенным ниже. [ошибка] ошибка при...
У меня есть следующий код: val conf = new SparkConf() .setAppName("KafkaReceiver")
Я хочу создать класс типов Scala Id, чтобы, например, я мог объявить, что Id для типа Foo принимает...