При использовании Java s3 sdk aws-java-sdk-s3:1.11.542 в Scala я получаю «Идентификатор ключа...

Учитывая данные, которые я извлек из Kafka. Как извлечь из него значения с помощью сопоставления с...

Я занимаюсь разработкой приложения, которое получает текстовые команды: Например, текстовая команда...

У меня есть DataFrame и список столбцов в виде строк, и мне нужно добавить столбец к исходному...

Spark 2.4.0 на Java 1.8.0_161 (Scala 2.11.12) Команда запуска: spark-shell --jars=spark-avro_2.11-2

Я новичок в Scala и RDD. Я использую Scala на Spark 2.4. У меня есть RDD [String] с такими...

В настоящее время необязательные типы (например, Option[String]), помеченные @QuerySqlField,...

Я хотел бы отфильтровать TXT-файл для создания СДР и создания статистики. Метод фильтра (.filter)...

Я слежу за функциональным программированием в книге Scala. Вот фрагмент кода из определения потока...

У меня есть следующая функция, которая имеет дело с серией поисковых событий, которые должны быть...

Я пишу несколько интеграционных тестов, чтобы убедиться, что мой клиент в сервисе работает

код - val configDetails2 = configDetails1 .join(skuDetails, configDetails1.col("sku_num")...

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

Я хочу получить значение из другого ресурса базы данных на основе Java для данного значения столбца

У меня есть метод Test, который принимает один аргумент, который является HBase Result org.apache

У меня есть координаты RDD [(Int, Int)], и я хочу создать новый RDD [(Int, (Int, Int))], что...

Когда я использую каталог ниже для получения отметки времени со значением: 1552413600000, SHC...

// First using normal dictionary lookup def findElement(e: String, dict: Map[String, Any]):...

У меня есть следующий фрейм данных: скажем, DF1 как root |-- VARIANTS: string (nullable = true) |--...

Я пытаюсь запустить простой конвейер в Spark, однако при использовании CrossValidator () выдается...

Я применяю некоторые фильтры к кадрам данных в Spark 1.6 и Spark 2.2, и у меня совершенно другое...

Я пытаюсь определить UserDefinedType на основе String, но отличается от StringType в Spark 2.4.1,...

Я использовал функцию ST_Within в geoSpark.Но я получаю java.lang.UnsupportedOperationException:...

У меня странное поведение при создании Excel с POI . Всякий раз, когда у меня меньше ~ 135 строк, я...

На удаленном SFTP сервере у меня есть csv файл с некоторыми данными. Можно ли добавить данные...