Я ищу способ разделить все мои фреймы данных в моем приложении по размеру доступного ядра. Если мои...

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

У меня сборка spark v 2.3.2 на платформе с прямым порядком байтов, использующая сборку jdk 1.8...

Я пытаюсь получить смещения Кафки для моей работы Spark Batch.После получения смещений я хотел бы...

Программа пытается собрать результаты listOListsRDD, используя flatMap и map Tranformations....

Я только начал изучать spark и scala и тестировать некоторые преобразования и действия с RDD. Я...

Я изучаю Apache Spark и использую Java 8 и Spark Core 2.3.2. Я обнаружил, что когда я использую...

У меня есть несколько зависимостей в моем jar (spark-core и io.grpc), которые используют две версии...