У меня есть кадр данных, как показано ниже +----------+-----------+---------+-----+------+------+...

После прочтения официальной документации по тестированию Flink (https://ci.apache

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

Мне нужно читать файлы от поставщиков, которые могут стать довольно большими (несколько ГБ). Эти...

Я хотел бы периодически обновлять значение (используется позже) внутри http-сервера akka....

Я использую спарк 1.6. Мне нужно найти несколько процентилей для столбца в dataframe. Мои данные...

Написание моей первой спарк-программы и, наконец, некоторые базовые вещи работают, но теперь они...

Я пытаюсь зарегистрировать Spark UDF, чтобы помочь мне преобразовать строку XML из таблицы, но...

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

У меня есть СДР в этом формате: (Int, String, Double) = (Key, Currency, Amount) И еще один СДР со...

Я пытаюсь проанализировать набор XML-файлов, используя Scala и Spark. Я получаю данные для 'n'...

Я хочу прочитать схему avro из метаданных файла avro в scala. Я могу сделать это Python, но я не...

Я новичок в драйвере scala mongo. Отсюда следует код вставки документа https://mongodb.github

У меня есть переменная String, представляющая некоторый точечный JsPath (например, store.book[0]

Учитывая текст, я хочу сопоставить слова, предоставленные пользователем, и заменить их другим...

С помощью @Luis Miguel Mejía Suárez у меня есть динамически рассчитанная частичная функция для...

Ниже фрагмент кода отсюда , где fs - FileSystem и pp сканирование каталога: pp.foreach( p => {...

Я заметил, что при попытке собрать толстый jara для playframework 2.7 с play-ws (сборка sbt)...

Я формирую запрос в String Builder, как показано ниже: println (dataQuery) Execution started at...

Я получаю данные в двоичном формате avro (avro v. 1.8), и мне нужно отправить их дальше в формате...

Ввод данных кадра +-----------------+-------+ |Id | value | +-----------------+-------+ | 1622|...

У меня есть следующий RDD с тысячами записей в виде (Int, Double), в который я хотел бы добавить...

Я пишу запрос на соединение для 2-х фреймов. Я должен выполнить объединение на столбце, который...

У меня есть список объектов (например, Student (Name: String, RollNo: Int)), и есть ли способ...

Ожидание перезапуска сервера при работе с Play стоит нам много времени. В журнале я вижу, что...