Я использую spark-sql 2.4.1, spark-cassandra-connector_2.11-2.4.1.jar и java8.У меня есть сценарий,...

Приведенный ниже искровой структурированный потоковый код собирает данные из Kafka каждые 10...

Я новичок в Spark structured streaming, и меня неправильно поняли. Я хочу реализовать...

Существует ли эквивалентное понятие контрольной точки метаданных для пакетных заданий в Apache...

Я новичок в Spark и хочу внести изменения в существующий протобуф.После внесения изменений я хочу...

Я использую версию spark-sql 2.4.1, Джексон Джарс и Java 8. В моей программе / работе с искрой я...

Я использую структурированные потоковые записи загрузки из Redis, код ниже val image = spark

Я запускаю задание spark sql со следующими настройками. - executor-cores 2 \ --executor-memory 15g...

Я использую версию spark-sql-2.4.1 с Java 8. У меня есть raw_df со столбцом "eventTs", который...

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

Я использую spark-sql-2.4.1 с spark-cassandra-connector-2_11.jar Я пытаюсь присоединиться к...

Использование libs, spark-cassandra-connector_2-11.jar и spark-sql-2.4.1.jar Есть таблица Cassandra...

Я пытаюсь обработать запрос в Presto с использованием JDBC и передать набор результатов обратно в...

Я пытаюсь сохранить набор структурированных паровых данных в заданную таблицу Кассандры. Я...

Я сталкиваюсь с вышеуказанной ошибкой при попытке получить журналы из kafka-topic, обработать их и...

Я пытаюсь запустить upsert / delete некоторые значения в исходной таблице базы данных DB2, которая...

Я должен соединить 2 источника со своими данными потоковой передачи.Эти 2 источника будут...

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

Пример твиттера Dstream - плоская карта twitter_id с текстом Впервые в scala и spark streaming

Я получаю сообщение об ошибке «Нет плана для EventTimeWatermark» при выполнении запроса с удалением...

Я пытаюсь использовать indexedRDD для графа (graphx), но я не смог найти никакого способа, потому...

Я еще не выбрал потоковый фреймворк, но сейчас я возиться с Флинком. Но я открыт для использования...

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

У меня ниже полезной нагрузки в концентраторе событий, возможность рутировать то же самое, чтобы...

Используя потоковую передачу Spark в Java, я пытаюсь денормализовать два фрейма данных в один...